Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect(rabbitMqAddress string) (*amqp.Connection, *amqp.Channel)
Connects to a RabbitMQ instance
func DeclareQueues ¶
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 ResponseQueueName ¶
Given a queue name, returns its response queue name
Types ¶
Click to show internal directories.
Click to hide internal directories.