Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct { ChannelNotifyTimeout time.Duration // contains filtered or unexported fields }
func (*RabbitMQ) Channel ¶
Channel returns a new `*amqp.Channel` instance. You must call `defer channel.Close()` as soon as you obtain one. Sometimes the connection might be closed unintentionally so as a graceful handling, try to connect only once.
func (*RabbitMQ) Connection ¶
func (r *RabbitMQ) Connection() *amqp.Connection
Connection exposes the essentials of the current connection. You should not normally use this but it is there for special use cases.
Click to show internal directories.
Click to hide internal directories.