Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitClient ¶
type RabbitClient struct { ConnectionString string AutoACK bool QueueNames []string ConsumeQueues []string ExchangeNames []string DefaultContentType string Bindings []Binding PrefetchCount int ConsumeHandler func(queueName string, d amqp.Delivery) error // contains filtered or unexported fields }
func (*RabbitClient) Close ¶
func (c *RabbitClient) Close()
func (*RabbitClient) Consume ¶
func (c *RabbitClient) Consume() error
func (*RabbitClient) Init ¶
func (c *RabbitClient) Init()
Click to show internal directories.
Click to hide internal directories.