Package pulp :: Package messaging :: Module async :: Class ReplyConsumer

Class ReplyConsumer

endpoint.Endpoint --+    
                    |    
    consumer.Consumer --+
                        |
                       ReplyConsumer

A request, reply consumer.

Instance Methods

[hide private]

start(self, listener)
Start processing messages on the queue and forward to the listener.

source code

dispatch(self, envelope)
Dispatch received request.

source code

__getreply(self, envelope)

source code

Inherited from consumer.Consumer

__init__(self, destination, **other)

source code

str

address(self)
Get the AMQP address for this endpoint.

source code

str

id(self)
Get the endpoint id

source code

join(self)
Join the worker thread.

source code

open(self)
Open and configure the consumer.

source code

received(self, message)
Process received request.

source code

stop(self)
Stop processing requests.

source code

valid(self, envelope)
Check to see if the envelope is valid.

source code

Inherited from endpoint.Endpoint

__del__(self)

source code

__str__(self)

source code

ack(self)
Acknowledge all messages received on the session.

source code

close(self)
Close (shutdown) the endpoint.

source code

Connection

connection(self)
Get cached connection based on url.

source code

qpid.messaging.Session

session(self)
Get a session for the open connection.

source code

Class Methods

[hide private]

Inherited from endpoint.Endpoint

shutdown(cls)
Shutdown all connections.

source code

Class Variables

[hide private]

Inherited from endpoint.Endpoint

LOCALHOST = 'tcp://localhost:5672'

Connection connectons
An AMQP connection.

Instance Variables

[hide private]

any

listener
An reply listener.

Inherited from endpoint.Endpoint

str

uuid
The unique endpoint id.

Method Details

[hide private]

start(self, listener)

source code

Start processing messages on the queue and forward to the listener.

Parameters:

listener (Listener) - A reply listener.

Overrides: consumer.Consumer.start

dispatch(self, envelope)

source code

Dispatch received request.

Parameters:

envelope (Envelope) - The received envelope.

Overrides: consumer.Consumer.dispatch