Package pulp :: Package messaging :: Module consumer :: Class Reader

Class Reader

endpoint.Endpoint --+    
                    |    
             Consumer --+
                        |
                       Reader

Instance Methods

[hide private]

start(self)
Start processing messages on the queue.

source code

stop(self)
Stop processing requests.

source code

Envelope

next(self, timeout=90)
Get the next envelope from the queue.

source code

Envelope

search(self, sn, timeout=90)
Seach the reply queue for the envelope with the matching serial #.

source code

Inherited from Consumer

__init__(self, destination, **other)

source code

str

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

source code

dispatch(self, envelope)
Dispatch received request.

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

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]

Inherited from endpoint.Endpoint

str

uuid
The unique endpoint id.

Method Details

[hide private]

start(self)

source code

Start processing messages on the queue.

Overrides: Consumer.start: (inherited documentation)

stop(self)

source code

Stop processing requests.

Overrides: Consumer.stop: (inherited documentation)

next(self, timeout=90)

source code

Get the next envelope from the queue.

Parameters:

timeout (int) - The read timeout.

Returns: Envelope

The next envelope.

search(self, sn, timeout=90)

source code

Seach the reply queue for the envelope with the matching serial #.

Parameters:

sn (str) - The expected serial number.
timeout (int) - The read timeout.

Returns: Envelope

The next envelope.