Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct { Rabbit *Rabbit // contains filtered or unexported fields }
func NewConsumer ¶
func NewConsumer(config ConsumerConfig, rabbit *Rabbit) *Consumer
NewConsumer returns a consumer instance.
type ConsumerConfig ¶
type Rabbit ¶
type Rabbit struct {
// contains filtered or unexported fields
}
func NewRabbit ¶
func NewRabbit(config RabbitMQConfig) *Rabbit
NewRabbit returns a RabbitMQ instance.
func (*Rabbit) Connection ¶
func (r *Rabbit) Connection() (*amqp.Connection, error)
Connection returns exiting `*amqp.Connection` instance.
Click to show internal directories.
Click to hide internal directories.