The ceilometer.publisher.messaging Module

Publish a sample using the preferred RPC mechanism.

exception ceilometer.publisher.messaging.DeliveryFailure(message=None, cause=None)[source]

Bases: exceptions.Exception

class ceilometer.publisher.messaging.EventNotifierPublisher(conf, parsed_url)[source]

Bases: ceilometer.publisher.messaging.NotifierPublisher

class ceilometer.publisher.messaging.MessagingPublisher(conf, parsed_url)[source]

Bases: ceilometer.publisher.ConfigPublisherBase

flush()[source]
publish_events(events)[source]

Send an event message for publishing

Parameters:events – events from pipeline after transformation
publish_samples(samples)[source]

Publish samples on RPC.

Parameters:samples – Samples from pipeline after transformation.
class ceilometer.publisher.messaging.NotifierPublisher(conf, parsed_url, default_topic)[source]

Bases: ceilometer.publisher.messaging.MessagingPublisher

class ceilometer.publisher.messaging.SampleNotifierPublisher(conf, parsed_url)[source]

Bases: ceilometer.publisher.messaging.NotifierPublisher