Documentation ¶
Index ¶
- type Rabbit
- func (mq *Rabbit) GetQueue(name string, args amqp.Table) (queue amqp.Queue, err error)
- func (mq *Rabbit) ReceiveFromMQ(exchange, key, queue string, args amqp.Table) (msgs <-chan amqp.Delivery, err error)
- func (mq *Rabbit) Reconnect() (err error)
- func (mq *Rabbit) SendToDLQue(exchange, key, queue string, body []byte, args amqp.Table) (err error)
- func (mq *Rabbit) SendToQue(exchange, key string, body []byte) (err error)
- func (mq *Rabbit) SetQos(count, size int, global bool) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Rabbit ¶
type Rabbit struct {
// contains filtered or unexported fields
}
Rabbit
func (*Rabbit) ReceiveFromMQ ¶
func (mq *Rabbit) ReceiveFromMQ(exchange, key, queue string, args amqp.Table) (msgs <-chan amqp.Delivery, err error)
ReceiveFromMQ
func (*Rabbit) SendToDLQue ¶
Click to show internal directories.
Click to hide internal directories.