rabbitmq

func Connect ¶

func Connect(rabbitMqAddress string) (*amqp.Connection, *amqp.Channel)

Connects to a RabbitMQ instance

func DeclareQueues ¶

func DeclareQueues(ch *amqp.Channel, queueName string) (amqp.Queue, amqp.Queue)

Declares two queues: - "queueName" contains orders from the Orchestrator to the module - "queueName-response" contains response messages from the module to the Orchestrator

func OnMessageReceive ¶

func OnMessageReceive(ch *amqp.Channel, queueName string, callback Callback) chan bool

func ResponseQueueName ¶

func ResponseQueueName(queueName string) string

Given a queue name, returns its response queue name