amqp

Documentation

Index

• type Consumer
  • func New(name, url, queue, exchange string, oo ...OptionFunc) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Consume(ctx context.Context) (<-chan async.Message, <-chan error, error)
• type OptionFunc
  • func Buffer(buf int) OptionFunc
  • func Requeue(requeue bool) OptionFunc
  • func Timeout(timeout time.Duration) OptionFunc

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

Consumer defines a AMQP subscriber.

func New

func New(name, url, queue, exchange string, oo ...OptionFunc) (*Consumer, error)

New creates a new AMQP consumer with some defaults. Use option to change.

func (*Consumer) Close

func (c *Consumer) Close() error

Close handles closing channel and connection of AMQP.

func (*Consumer) Consume

func (c *Consumer) Consume(ctx context.Context) (<-chan async.Message, <-chan error, error)

Consume starts of consuming a AMQP queue.

type OptionFunc

type OptionFunc func(*Consumer) error

OptionFunc definition for configuring the consumer in a functional way.

func Buffer

func Buffer(buf int) OptionFunc

Buffer option for adjusting the incoming messages buffer.

func Requeue

func Requeue(requeue bool) OptionFunc

Requeue option for adjusting the requeue policy of a message.

func Timeout

func Timeout(timeout time.Duration) OptionFunc

Timeout option for adjusting the timeout of the connection.