Documentation
¶
Index ¶
- type MQ
- func (mq *MQ) BindQueueWithExchange(queue string, exchange string, key string, args amqp.Table)
- func (mq *MQ) Connect(connString string)
- func (mq *MQ) CreateChannel()
- func (mq *MQ) CreateExchange(name string, kind string, durable bool)
- func (mq *MQ) CreateQueue(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, ...)
- func (mq *MQ) EstablishWorker(queue string) <-chan amqp.Delivery
- func (mq *MQ) Publish(exchange string, queue string, data interface{})
- func (mq *MQ) WriteToQueue(queue string, data interface{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQ ¶
type MQ struct {
// contains filtered or unexported fields
}
MQ structure
func (*MQ) BindQueueWithExchange ¶
BindQueueWithExchange function
func (*MQ) CreateExchange ¶
CreateExchange to create new exchange
func (*MQ) CreateQueue ¶
func (mq *MQ) CreateQueue(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table)
CreateQueue in mq
func (*MQ) EstablishWorker ¶
EstablishWorker method
func (*MQ) WriteToQueue ¶
WriteToQueue function
Source Files
Click to show internal directories.
Click to hide internal directories.