rez.utils.amqp

rez.utils.amqp.publish_message(host, amqp_settings, routing_key, data, block=True)

Publish an AMQP message.

Returns:

True if message was sent successfully.

Return type:

bool

rez.utils.amqp.on_exit()

rez.utils.amqp.parse_host_and_port(url)

rez.utils.amqp.set_pika_log_level()