Versions in this module Expand all Collapse all v1 v1.0.0 May 14, 2016 Changes in this version + func Acknowledge(msg message.HttpRequestMessage, logFile *logfile.Logger) (err error) + func GetDeliveryChan(size int) <-chan amqp.Delivery + func QueueCheck(config *config.ConfigParameters) error + func QueueDelete(config *config.ConfigParameters) error + type Delivery amqp.Delivery + type RMQConnection struct + func (rmq *RMQConnection) Close() + func (rmq *RMQConnection) Open(config *config.ConfigParameters, logFile *logfile.Logger) (<-chan amqp.Delivery, <-chan *amqp.Error, error)
Go to main page