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

Class Endpoint

source code

Known Subclasses:

Base class for QPID endpoint.

Instance Methods [hide private]
 
__init__(self, uuid=None, url=None) 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
 
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
 
_lock(self) source code
 
_unlock(self) source code
 
__parsedurl(self) source code
 
__del__(self) source code
 
__str__(self) source code
Class Variables [hide private]
  LOCALHOST = 'tcp://localhost:5672'
SessionPool ssnpool = SessionPool()
An AMQP session pool.
Instance Variables [hide private]
RLock __mutex
The endpoint mutex.
qpid.messaging.Session __session
An AMQP session.
str url
The broker URL.
str uuid
The unique endpoint id.
Method Details [hide private]

__init__(self, uuid=None, url=None)
(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.

session(self)

source code 

Get a session for the open connection.

Returns: qpid.messaging.Session
An open session.