The ceilometer.openstack.common.rpc.impl_qpid Module

class ceilometer.openstack.common.rpc.impl_qpid.Connection(conf, server_params=None)[source]

Bases: object

Connection object.

cancel_consumer_thread()[source]

Cancel a consumer thread

close()[source]

Close/release this connection

connection_create(broker)[source]
consume(limit=None)[source]

Consume from all queues/consumers

consume_in_thread()[source]

Consumer from all queues/consumers in a greenthread

create_consumer(topic, proxy, fanout=False)[source]

Create a consumer that calls a method in a proxy object

create_worker(topic, proxy, pool_name)[source]

Create a worker that calls a method in a proxy object

declare_consumer(consumer_cls, topic, callback)[source]

Create a Consumer using the class that was passed in and add it to our list of consumers

declare_direct_consumer(topic, callback)[source]

Create a ‘direct’ queue. In nova’s use, this is generally a msg_id queue used for responses for call/multicall

declare_fanout_consumer(topic, callback)[source]

Create a ‘fanout’ consumer

declare_topic_consumer(topic, callback=None, queue_name=None, exchange_name=None)[source]

Create a ‘topic’ consumer.

direct_send(msg_id, msg)[source]

Send a ‘direct’ message

ensure(error_callback, method, *args, **kwargs)[source]
fanout_send(topic, msg)[source]

Send a ‘fanout’ message

iterconsume(limit=None, timeout=None)[source]

Return an iterator that will consume from all queues/consumers

join_consumer_pool(callback, pool_name, topic, exchange_name=None)[source]

Register as a member of a group of consumers for a given topic from the specified exchange.

Exactly one member of a given pool will receive each message.

A message will be delivered to multiple pools, if more than one is created.

notify_send(topic, msg, **kwargs)[source]

Send a notify message on a topic

publisher_send(cls, topic, msg)[source]

Send to a publisher based on the publisher class

reconnect()[source]

Handles reconnecting and re-establishing sessions and queues

reset()[source]

Reset a connection so it can be used again

topic_send(topic, msg, timeout=None)[source]

Send a ‘topic’ message

wait_on_proxy_callbacks()[source]

Wait for all proxy callback threads to exit.

class ceilometer.openstack.common.rpc.impl_qpid.ConsumerBase(session, callback, node_name, node_opts, link_name, link_opts)[source]

Bases: object

Consumer base class.

consume()[source]

Fetch the message and pass it to the callback object

get_receiver()[source]
reconnect(session)[source]

Re-declare the receiver after a qpid reconnect

class ceilometer.openstack.common.rpc.impl_qpid.DirectConsumer(conf, session, msg_id, callback)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.ConsumerBase

Queue/consumer class for ‘direct’

class ceilometer.openstack.common.rpc.impl_qpid.DirectPublisher(conf, session, msg_id)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.Publisher

Publisher class for ‘direct’

class ceilometer.openstack.common.rpc.impl_qpid.FanoutConsumer(conf, session, topic, callback)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.ConsumerBase

Consumer class for ‘fanout’

class ceilometer.openstack.common.rpc.impl_qpid.FanoutPublisher(conf, session, topic)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.Publisher

Publisher class for ‘fanout’

class ceilometer.openstack.common.rpc.impl_qpid.NotifyPublisher(conf, session, topic)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.Publisher

Publisher class for notifications

class ceilometer.openstack.common.rpc.impl_qpid.Publisher(session, node_name, node_opts=None)[source]

Bases: object

Base Publisher class

reconnect(session)[source]

Re-establish the Sender after a reconnection

send(msg)[source]

Send a message

class ceilometer.openstack.common.rpc.impl_qpid.TopicConsumer(conf, session, topic, callback, name=None, exchange_name=None)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.ConsumerBase

Consumer class for ‘topic’

class ceilometer.openstack.common.rpc.impl_qpid.TopicPublisher(conf, session, topic)[source]

Bases: ceilometer.openstack.common.rpc.impl_qpid.Publisher

Publisher class for ‘topic’

Previous topic

The ceilometer.openstack.common.rpc.impl_kombu Module

Next topic

The ceilometer.openstack.common.rpc.impl_zmq Module

This Page