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: nova.openstack.common.rpc.impl_qpid.ConsumerBase
Queue/consumer class for ‘direct’
Bases: nova.openstack.common.rpc.impl_qpid.Publisher
Publisher class for ‘direct’
Bases: nova.openstack.common.rpc.impl_qpid.ConsumerBase
Consumer class for ‘fanout’
Bases: nova.openstack.common.rpc.impl_qpid.Publisher
Publisher class for ‘fanout’
Bases: nova.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: nova.openstack.common.rpc.impl_qpid.ConsumerBase
Consumer class for ‘topic’
Bases: nova.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.