Package gofer :: Package rmi :: 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, options) 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
 
notifywatchdog(self, sn, replyto, any)
Add the request to the watchdog for tacking.
source code
Instance Variables [hide private]

Inherited from RequestMethod: producer

Method Details [hide private]

__init__(self, producer, options)
(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. A trigger(1) specifies a manual trigger.

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. A trigger(1) specifies a manual trigger.

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.

notifywatchdog(self, sn, replyto, any)

source code 

Add the request to the watchdog for tacking.

Parameters:
  • sn (str) - A serial number.
  • replyto (str) - An AMQP address.
  • any (any) - User defined data.