The ceilometer.messaging Module¶

ceilometer.messaging.cleanup()[source]¶

Cleanup the oslo_messaging layer.

ceilometer.messaging.get_batch_notification_listener(transport, targets, endpoints, allow_requeue=False, batch_size=1, batch_timeout=None)[source]¶

Return a configured oslo_messaging notification listener.

ceilometer.messaging.get_notifier(transport, publisher_id)[source]¶

Return a configured oslo_messaging notifier.

ceilometer.messaging.get_transport(conf, url=None, optional=False, cache=True)[source]¶

Initialise the oslo_messaging layer.

ceilometer.messaging.setup()[source]¶