Package gofer :: Package rmi :: Module consumer :: Class RequestConsumer
[hide private]
[frames] | no frames]

Class RequestConsumer

source code

messaging.endpoint.Endpoint --+    
    messaging.consumer.Consumer --+

Reply consumer. Reads messages from AMQP and writes to local pending queue to be consumed by the scheduler.

Instance Methods [hide private]
dispatch(self, envelope)
Dispatch received request.
source code

Inherited from messaging.consumer.Consumer: __init__, address, close, id, join, received, start, stop, valid

Inherited from messaging.endpoint.Endpoint: __del__, __str__, ack, open, session

Inherited from messaging.endpoint.Endpoint (private): _lock, _unlock

Class Methods [hide private]

Inherited from messaging.consumer.Consumer: subject

Class Variables [hide private]

Inherited from messaging.endpoint.Endpoint: LOCALHOST, ssnpool

Instance Variables [hide private]

Inherited from messaging.endpoint.Endpoint: url, uuid

Method Details [hide private]

dispatch(self, envelope)

source code 

Dispatch received request.

  • envelope (Envelope) - The received envelope.
Overrides: messaging.consumer.Consumer.dispatch