Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rabbitmqutils

package module

Go to main page

Versions in this module

v1

v1.1.4

Nov 16, 2021

v1.1.3

Aug 4, 2021

Changes in this version

type Client

+ func (client Client) GetMessage(queue string) (amqp.Delivery, error)

type MessageBrokerChannel

+ Get func(queueName string, autoAcknowledge bool) (message amqp.Delivery, ok bool, err error)

v1.1.2

Jul 25, 2021

v1.1.1

Jun 17, 2021

Changes in this version

+ type AMQPAcknowledger interface

+ type Acknowledger struct

+ Logger log.Logger

+ MessageHandler FailingMessageHandler

+ MessageHandling MessageHandling

+ func (acknowledger Acknowledger) HandleMessage(message amqp.Delivery)

+ type Client struct

+ func NewClient(dsn string, options ...ClientOption) (Client, error)

+ func (client Client) CancelConsuming(queue string) error

+ func (client Client) Close() error

+ func (client Client) ConsumeMessages(queue string) (<-chan amqp.Delivery, error)

+ func (client Client) PublishMessage(queue string, messageID string, messageData interface{}) error

+ type ClientConfig struct

+ type ClientOption func(clientConfig *ClientConfig)

+ func WithClock(clock Clock) ClientOption

+ func WithDialer(dialer Dialer) ClientOption

+ func WithIDGenerator(idGenerator IDGenerator) ClientOption

+ func WithMaximalQueueSize(maximalQueueSize int) ClientOption

+ func WithQueues(queues []string) ClientOption

+ type Clock func() time.Time

+ type ClockInterface interface

+ Time func() time.Time

+ type ConnectionWrapper struct

+ func (wrapper ConnectionWrapper) Channel() (MessageBrokerChannel, error)

+ type ContextCancellerInterface interface

+ CancelContext func()

+ type Dialer func(dsn string) (MessageBrokerConnection, error)

+ type DialerInterface interface

+ Dial func(dsn string) (MessageBrokerConnection, error)

+ type FailingMessageHandler interface

+ HandleMessage func(message amqp.Delivery) error

+ type IDGenerator func() (string, error)

+ type IDGeneratorInterface interface

+ GenerateID func() (string, error)

+ type JSONMessageHandler struct

+ MessageHandler SpecificMessageHandler

+ func (handler JSONMessageHandler) HandleMessage(message amqp.Delivery) error

+ type Logger interface

+ type MessageBrokerChannel interface

+ Cancel func(consumerName string, noWait bool) error

+ Close func() error

+ Consume func(queueName string, consumerName string, autoAcknowledge bool, exclusive bool, ...) (<-chan amqp.Delivery, error)

+ Publish func(exchange string, queueName string, mandatory bool, immediate bool, ...) error

+ Qos func(prefetchCount int, prefetchSize int, global bool) error

+ QueueDeclare func(queueName string, durable bool, autoDelete bool, exclusive bool, noWait bool, ...) (amqp.Queue, error)

+ type MessageBrokerConnection interface

+ Channel func() (MessageBrokerChannel, error)

+ Close func() error

+ type MessageConsumer struct

+ func NewMessageConsumer(client MessageConsumerClient, queue string, messageHandler MessageHandler) (MessageConsumer, error)

+ func (consumer MessageConsumer) Start()

+ func (consumer MessageConsumer) StartConcurrently(concurrency int)

+ func (consumer MessageConsumer) Stop() error

+ type MessageConsumerClient interface

+ CancelConsuming func(queue string) error

+ ConsumeMessages func(queue string) (<-chan amqp.Delivery, error)

+ type MessageHandler interface

+ HandleMessage func(message amqp.Delivery)

+ type MessageHandling int

+ const OnceMessageHandling

+ const TwiceMessageHandling

+ type SpecificMessageHandler interface

+ HandleMessage func(message interface{}) error

+ MessageType func() reflect.Type