Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RmqConnection ¶
type RmqConnection struct { ConsumerExchange string RmqConfig Connection *amqp.Connection Channel *amqp.Channel Delivery <-chan amqp.Delivery }
func New ¶
func New(consumerExchange string, cfg RmqConfig) *RmqConnection
func (*RmqConnection) AttemptsConnect ¶
func (c *RmqConnection) AttemptsConnect() error
Click to show internal directories.
Click to hide internal directories.