Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Acknowledge ¶
func Acknowledge(msg message.HttpRequestMessage, logFile *logfile.Logger) (err error)
func GetDeliveryChan ¶
func QueueCheck ¶
func QueueCheck(config *config.ConfigParameters) error
QueueCheck creates/verifies RabbitMQ queues
func QueueDelete ¶
func QueueDelete(config *config.ConfigParameters) error
QueueDelete removes RabbitMQ queues if they are not currently in use
Types ¶
type RMQConnection ¶
type RMQConnection struct {
// contains filtered or unexported fields
}
func (*RMQConnection) Close ¶
func (rmq *RMQConnection) Close()
Click to show internal directories.
Click to hide internal directories.