Documentation
¶
Index ¶
- Constants
- type Binding
- type Connection
- type Declaration
- type Declarator
- type Exchange
- type PublishExchange
- type Publisher
- type Queue
- type Session
- func (s *Session) AddPublisher(exchangeName, routingKey string) error
- func (s *Session) AddSubscription(exchangeName, queueName, routingKey string, handler Subscriber) error
- func (s *Session) Consume()
- func (s *Session) Declare() error
- func (s *Session) Publish(routingKey string, event interface{}) error
- func (s *Session) Shutdown()
- type Subscriber
Constants ¶
const ReconnectDelay = 5 * time.Second
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
Connection is a wrapper for amqp.Connection but adding reconnection functionality.
func NewConnection ¶
func NewConnection(addr string, logger *zap.Logger) *Connection
func (*Connection) Connect ¶
func (c *Connection) Connect() (err error)
Connect will dial to the specified AMQP server addr.
func (*Connection) IsConnected ¶
func (c *Connection) IsConnected() bool
func (*Connection) Shutdown ¶
func (c *Connection) Shutdown()
Shutdown the reconnector and terminate any existing connections
type Declaration ¶
type Declaration func(Declarator) error
func AutoBinding ¶
func AutoBinding(routingKey, queue, exchange string) Declaration
func AutoExchange ¶
func AutoExchange(name string) Declaration
func AutoQueue ¶
func AutoQueue(name string) Declaration
func DeclareBinding ¶
func DeclareBinding(b *Binding) Declaration
func DeclareExchange ¶
func DeclareExchange(e *Exchange) Declaration
func DeclareQueue ¶
func DeclareQueue(q *Queue) Declaration
type Declarator ¶
type Declarator interface {
QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
}
Declarator is implemented by amqp.Channel
type PublishExchange ¶
type PublishExchange string
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
func (*Session) AddPublisher ¶
AddPublisher is a wrapper to convenitently prepare the session for publishing on a specific exchange. The method ensures that the target exchange is declared when calling Declare().
func (*Session) AddSubscription ¶
func (s *Session) AddSubscription(exchangeName, queueName, routingKey string, handler Subscriber) error
AddSubscription is a wrapper which uses the Auto*() functions to quickly add an exchange, queue and binding to the declarations list. It will also register the subscriber handler function with the subscriber map. If no connection for the consumer exist, the connection is established at this point. This happens only once, even if you add multiple subscriptions.
func (*Session) Declare ¶
Declare goes through all declarations and uses the consumer/produce connection to obtain a channel and perform the declarations.
Source Files