Connects to the RabbitMQ middleware

Disconnects from the RabbitMQ connection

Calculate the exponential backoff needed

looks up a boolean value in the config

Returns the name of the certificate file used by RabbitMQ Will first check if an environment variable MCOLLECTIVE_RABBITMQ_POOLX_SSL_CERT exists, where X is the RabbitMQ pool number. If the environment variable doesn‘t exist, it will try and load the value from the config.

looks in the environment first then in the config file for a specific option, accepts an optional default.

raises an exception when it cant find a value anywhere

Returns the name of the private key file used by RabbitMQ Will first check if an environment variable MCOLLECTIVE_RABBITMQ_POOLX_SSL_KEY exists, where X is the RabbitMQ pool number. If the environment variable doesn‘t exist, it will try and load the value from the config.

looks for a config option, accepts an optional default

raises an exception when it cant find a value anywhere

Sends a message to the RabbitMQ connection

Receives a message from the RabbitMQ connection

Sets the SSL paramaters for a specific connection

Subscribe to a topic or queue

Subscribe to a topic or queue