rabbit

Mar 18, 2019

Changes in this version

+ var ErrAlreadyStarted = errors.New("Already started")

+ var ErrAlreadyStopped = errors.New("Already closed")

+ var ErrHandlerRequired = errors.New("Handler is required")

+ var ErrNameRequired = errors.New("Name is required")

+ var ErrSubIsClosed = errors.New("Subscription is closed. Try to create a new one")

+ func CloseDefaultClient()

+ func IsInitialized() bool

+ type Client struct

+ func GetDefaultClient() *Client

+ func InitDefaultClient(cfg RabbitConfig) *Client

+ func MakeClient(config RabbitConfig) (*Client, error)

+ func (c *Client) Close(eh ErrHandler)

+ func (c *Client) Declare(dls ...Declaration) error

+ func (c *Client) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

+ func (c *Client) Subscribe(req SubRequest) (*Subscription, error)

+ type Declaration func(c *amqp.Channel) error

+ func DeclareExchange(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) Declaration

+ func DeclareQueue(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) Declaration

+ func DeclateBinding(name, key, exchange string, noWait bool, args amqp.Table) Declaration

+ type DisconnectionHandler func(err *amqp.Error)

+ type ErrHandler func(err error)

+ type MsgHandler func(d amqp.Delivery)

+ type RabbitConfig struct

+ Address structure.AddressConfiguration

+ DisconnectionHandler DisconnectionHandler

+ Password string

+ ReconnectionErrorHandler ErrHandler

+ SubscriptionErrorHandler ErrHandler

+ User string

+ Vhost string

+ func (rc RabbitConfig) GetUri() string

+ type SubRequest struct

+ ConcurrentConsumers int

+ Handler MsgHandler

+ Name string

+ PrefetchSize int

+ Queue string

+ type Subscription struct

+ func (s *Subscription) Close(eh ErrHandler)

+ func (s *Subscription) GetRequest() SubRequest

+ func (s *Subscription) IsActive() bool

+ func (s *Subscription) Start() error

+ func (s *Subscription) Stop() error