Package pulp :: Package messaging :: Module producer :: Class Producer

Class Producer

endpoint.Endpoint --+
                    |
                   Producer

An AMQP (abstract) message producer.

Instance Methods

[hide private]

open(self)
Open and configure the producer.

source code

str

send(self, destination, **body)
Send a message.

source code

list

broadcast(self, destinations, **body)
Broadcast a message to (N) queues.

source code

Inherited from endpoint.Endpoint

__del__(self)

source code

__init__(self, uuid=getuuid(), url=LOCALHOST)

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

str

id(self)
Get the endpoint id

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]

open(self)

source code

Open and configure the producer.

Overrides: endpoint.Endpoint.open

send(self, destination, **body)

source code

Send a message.

Parameters:

destination (Destination) - An AMQP destination.
body - envelope body.

Returns: str

The message serial number.

broadcast(self, destinations, **body)

source code

Broadcast a message to (N) queues.

Parameters:

destinations ([Destination,..]) - A list of AMQP destinations.
body - envelope body.

Returns: list

A list of (addr,sn).