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(parsed_url)[source]

Bases: ceilometer.publisher.messaging.NotifierPublisher

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

Bases: ceilometer.publisher.PublisherBase

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(parsed_url, default_topic)[source]

Bases: ceilometer.publisher.messaging.MessagingPublisher

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

Bases: ceilometer.publisher.messaging.NotifierPublisher

Previous topic

The ceilometer.publisher.kafka_broker Module

Next topic

The ceilometer.publisher.test Module

Project Source

This Page