Bases: object
Connection object.
Cancel a consumer thread.
Close/release this connection.
Consume from all queues/consumers.
Consumer from all queues/consumers in a greenthread.
Create a consumer that calls a method in a proxy object.
Create a worker that calls a method in a proxy object.
Create a Consumer using the class that was passed in and add it to our list of consumers
Create a ‘direct’ queue. In nova’s use, this is generally a msg_id queue used for responses for call/multicall
Create a ‘fanout’ consumer.
Create a ‘topic’ consumer.
Send a ‘direct’ message.
Send a ‘fanout’ message.
Return an iterator that will consume from all queues/consumers.
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.
Send a notify message on a topic.
Send to a publisher based on the publisher class.
Handles reconnecting and re-establishing sessions and queues.
Reset a connection so it can be used again.
Send a ‘topic’ message.
Wait for all proxy callback threads to exit.
Bases: object
Consumer base class.
Fetch the message and pass it to the callback object.
Re-declare the receiver after a qpid reconnect.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.ConsumerBase
Queue/consumer class for ‘direct’.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.Publisher
Publisher class for ‘direct’.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.ConsumerBase
Consumer class for ‘fanout’.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.Publisher
Publisher class for ‘fanout’.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.Publisher
Publisher class for notifications.
Bases: object
Base Publisher class.
Re-establish the Sender after a reconnection.
Send a message.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.ConsumerBase
Consumer class for ‘topic’.
Bases: openstack_dashboard.openstack.common.rpc.impl_qpid.Publisher
Publisher class for ‘topic’.
Sends a message on a topic and wait for a response.
Sends a message on a topic without waiting for a response.
Sends a message on a topic to a specific server.
Create a connection.
Sends a message on a fanout exchange without waiting for a response.
Sends a message on a fanout exchange to a specific server.
Make a call that returns multiple times.
Sends a notification event on a topic.