rez.utils.amqp

rez.utils.amqp.on_exit()[source]

rez.utils.amqp.parse_host_and_port(url)[source]

rez.utils.amqp.publish_message(host, amqp_settings, routing_key, data, block=True)[source]

Publish an AMQP message.

Returns: True if message was sent successfully.
Return type: bool

rez.utils.amqp.set_pika_log_level()[source]