Package pulp :: Package messaging :: Module producer :: Class EventProducer

Class EventProducer

endpoint.Endpoint --+    
                    |    
             Producer --+
                        |
                       EventProducer

Event producer.

Instance Methods

[hide private]

str

send(self, subject, event)
Send an event.

source code

Inherited from Producer

list

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

source code

open(self)
Open and configure the producer.

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]

send(self, subject, event)

source code

Send an event.

Parameters:

subject (str) - A subject.
event (object) - The event body

Returns: str

The message serial number.

Overrides: Producer.send