amqp

Documentation

Overview

Package amqp provides consumer implementation with included tracing capabilities.

Index

• type Exchange
  • func NewExchange(name, kind string) (*Exchange, error)
• type Factory
  • func New(url, queue string, exchange Exchange, oo ...OptionFunc) (*Factory, error)
  • func (f *Factory) Create() (async.Consumer, error)
• type OptionFunc
  • func Bindings(bindings ...string) OptionFunc
  • func Buffer(buf int) OptionFunc
  • func Requeue(requeue bool) OptionFunc
  • func Timeout(timeout time.Duration) OptionFunc

Types

type Exchange

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

Exchange represents an AMQP exchange.

func NewExchange

func NewExchange(name, kind string) (*Exchange, error)

NewExchange validates its input and creates a new Exchange. name should be a non empty string, kind should be one of: [direct, fanout, topic, headers].

type Factory

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

Factory of an AMQP consumer.

func New

func New(url, queue string, exchange Exchange, oo ...OptionFunc) (*Factory, error)

New constructor.

func (*Factory) Create

func (f *Factory) Create() (async.Consumer, error)

Create a new consumer.

type OptionFunc

type OptionFunc func(*consumer) error

OptionFunc definition for configuring the consumer in a functional way.

func Bindings

func Bindings(bindings ...string) OptionFunc

Bindings option for providing custom exchange-queue bindings.

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.