Documentation
¶
Index ¶
- func AmqpPublisher(cfg *config.Configuration, id int, amqpStatus chan int, ...)
- func AmqpWorker(cfg *config.Configuration, workId int, amqpStatus chan int)
- func CleanupConnection(workerId string, connection *amqp.Connection)
- func ConsumeQueue(connection *amqp.Connection, exchange string, exchangeType string, ...)
- func OpenConnection(amqpURI string, workerId string) (*amqp.Connection, error)
- func Reconnect(amqpURI string, workerId string, conn *amqp.Connection, err *amqp.Error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AmqpPublisher ¶
func AmqpPublisher(cfg *config.Configuration, id int, amqpStatus chan int, amqpMessages chan []byte)
func AmqpWorker ¶
func AmqpWorker(cfg *config.Configuration, workId int, amqpStatus chan int)
func CleanupConnection ¶
func CleanupConnection(workerId string, connection *amqp.Connection)
func ConsumeQueue ¶
func OpenConnection ¶
func OpenConnection(amqpURI string, workerId string) (*amqp.Connection, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.