Package pulp :: Package messaging :: Module policy :: Class Asynchronous
[hide private]
[frames] | no frames]

Class Asynchronous

source code

RequestMethod --+
                |
               Asynchronous

The asynchronous request method.

Instance Methods [hide private]
 
__init__(self, producer, tag=None) source code
str
send(self, destination, request, **any)
Send the specified request and redirect the reply to the queue for the specified reply correlation tag.
source code
 
broadcast(self, destinations, request, **any)
Send the specified request and redirect the reply to the queue for the specified reply correlation tag.
source code
str
__replyto(self)
Get replyto based on the correlation tag.
source code
    Inherited from RequestMethod
 
close(self)
Close and release all resources.
source code
Instance Variables [hide private]
    Inherited from RequestMethod
pulp.messaging.producer.Producer producer
A queue producer.
Method Details [hide private]

__init__(self, producer, tag=None)
(Constructor)

source code 
Parameters:
Overrides: RequestMethod.__init__

send(self, destination, request, **any)

source code 

Send the specified request and redirect the reply to the queue for the specified reply correlation tag.

Parameters:
  • destination (Destination) - The AMQP destination.
  • request (object) - A request to send.
  • any - Any (extra) data.
Returns: str
The request serial number.
Overrides: RequestMethod.send

broadcast(self, destinations, request, **any)

source code 

Send the specified request and redirect the reply to the queue for the specified reply correlation tag.

Parameters:
  • destinations ([Destination,..]) - A list of destinations.
  • request (object) - A request to send.
  • any - Any (extra) data.
Overrides: RequestMethod.broadcast

__replyto(self)

source code 

Get replyto based on the correlation tag.

Returns: str
The replyto AMQP address.