Package pulp :: Package messaging :: Module endpoint :: Class Endpoint
[hide private]
[frames] | no frames]

Class Endpoint

source code

Base class for QPID endpoint.

Instance Methods [hide private]
 
__init__(self, uuid=getuuid(), url=LOCALHOST) source code
str
id(self)
Get the endpoint id
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
 
ack(self)
Acknowledge all messages received on the session.
source code
 
open(self)
Open and configure the endpoint.
source code
 
close(self)
Close (shutdown) the endpoint.
source code
 
__parsedurl(self) source code
 
__del__(self) source code
 
__str__(self) source code
Class Methods [hide private]
 
shutdown(cls)
Shutdown all connections.
source code
Class Variables [hide private]
  LOCALHOST = 'tcp://localhost:5672'
Connection connectons
An AMQP connection.
Instance Variables [hide private]
qpid.messaging.Session __session
An AMQP session.
str uuid
The unique endpoint id.
Method Details [hide private]

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

source code 
Parameters:
  • uuid (str) - The endpoint uuid.
  • url (str) - The broker url <transport>://<user>/<pass>@<host>:<port>.

id(self)

source code 

Get the endpoint id

Returns: str
The id.

connection(self)

source code 

Get cached connection based on url.

Returns: Connection
The global connection.

session(self)

source code 

Get a session for the open connection.

Returns: qpid.messaging.Session
An open session.