Package gofer :: Package rmi :: Module consumer :: Class RequestConsumer

Class RequestConsumer

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

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.

Parameters:

envelope (Envelope) - The received envelope.

Overrides: messaging.consumer.Consumer.dispatch