The openstack_dashboard.openstack.common.rpc.impl_qpid ModuleΒΆ

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

Bases: object

Connection object.

Connection.cancel_consumer_thread()[source]

Cancel a consumer thread.

Connection.close()[source]

Close/release this connection.

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

Consume from all queues/consumers.

Connection.consume_in_thread()[source]

Consumer from all queues/consumers in a greenthread.

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

Create a consumer that calls a method in a proxy object.

Connection.create_worker(topic, proxy, pool_name)[source]

Create a worker that calls a method in a proxy object.

Connection.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

Connection.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

Connection.declare_fanout_consumer(topic, callback)[source]

Create a ‘fanout’ consumer.

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

Create a ‘topic’ consumer.

Connection.direct_send(msg_id, msg)[source]

Send a ‘direct’ message.

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

Send a ‘fanout’ message.

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

Return an iterator that will consume from all queues/consumers.

Connection.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.

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

Send a notify message on a topic.

Connection.pool = None
Connection.publisher_send(cls, topic, msg)[source]

Send to a publisher based on the publisher class.

Connection.reconnect()[source]

Handles reconnecting and re-establishing sessions and queues.

Connection.reset()[source]

Reset a connection so it can be used again.

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

Send a ‘topic’ message.

Connection.wait_on_proxy_callbacks()[source]

Wait for all proxy callback threads to exit.

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

Bases: object

Consumer base class.

ConsumerBase.consume()[source]

Fetch the message and pass it to the callback object.

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

Re-declare the receiver after a qpid reconnect.

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

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

Queue/consumer class for ‘direct’.

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

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

Publisher class for ‘direct’.

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

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

Consumer class for ‘fanout’.

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

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

Publisher class for ‘fanout’.

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

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

Publisher class for notifications.

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

Bases: object

Base Publisher class.

Publisher.reconnect(session)[source]

Re-establish the Sender after a reconnection.

Publisher.send(msg)[source]

Send a message.

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

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

Consumer class for ‘topic’.

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

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

Publisher class for ‘topic’.

openstack_dashboard.openstack.common.rpc.impl_qpid.call(conf, context, topic, msg, timeout=None)[source]

Sends a message on a topic and wait for a response.

openstack_dashboard.openstack.common.rpc.impl_qpid.cast(conf, context, topic, msg)[source]

Sends a message on a topic without waiting for a response.

openstack_dashboard.openstack.common.rpc.impl_qpid.cast_to_server(conf, context, server_params, topic, msg)[source]

Sends a message on a topic to a specific server.

openstack_dashboard.openstack.common.rpc.impl_qpid.cleanup()[source]
openstack_dashboard.openstack.common.rpc.impl_qpid.create_connection(conf, new=True)[source]

Create a connection.

openstack_dashboard.openstack.common.rpc.impl_qpid.fanout_cast(conf, context, topic, msg)[source]

Sends a message on a fanout exchange without waiting for a response.

openstack_dashboard.openstack.common.rpc.impl_qpid.fanout_cast_to_server(conf, context, server_params, topic, msg)[source]

Sends a message on a fanout exchange to a specific server.

openstack_dashboard.openstack.common.rpc.impl_qpid.multicall(conf, context, topic, msg, timeout=None)[source]

Make a call that returns multiple times.

openstack_dashboard.openstack.common.rpc.impl_qpid.notify(conf, context, topic, msg, envelope)[source]

Sends a notification event on a topic.

Previous topic

The openstack_dashboard.openstack.common.rpc.proxy Module

Next topic

The openstack_dashboard.openstack.common.rpc.zmq_receiver Module

This Page