Package gofer :: Package messaging :: Module broker :: Class Broker
[hide private]
[frames] | no frames]

Class Broker

source code

object --+
         |
        Broker

Represents an AMQP broker.

Nested Classes [hide private]
  __metaclass__
Broker MetaClass.
Instance Methods [hide private]
 
__init__(self, url)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
str
id(self)
Get broker identifier.
source code
Connection
connect(self)
Connect to the broker.
source code
 
touch(self, address)
Touch (eval) the specified AMQP address string.
source code
 
close(self)
Close the connection to the broker.
source code
 
__str__(self)
str(x)
source code

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __subclasshook__

Class Methods [hide private]
 
__lock(cls) source code
 
__unlock(cls) source code
Class Variables [hide private]
  __mutex = <_RLock owner=None count=0>
dict domain
A list dict of brokers.
Instance Variables [hide private]
str cacert
Path to a PEM encoded file containing the CA certificate used to validate the server certificate.
str clientcert
Path to a PEM encoded file containing the private key & certificate used for client authentication.
URL url
The broker's url.
Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, url)
(Constructor)

source code 

x.__init__(...) initializes x; see help(type(x)) for signature

Parameters:
  • url (str) - The broker url <transport>://<host>:<port>.
Overrides: object.__init__

id(self)

source code 

Get broker identifier.

Returns: str
The broker simple url.

connect(self)

source code 

Connect to the broker.

Returns: Connection
The AMQP connection object.

touch(self, address)

source code 

Touch (eval) the specified AMQP address string. Used to perform destination administration. Examples:

  • myqueue;{delete:always}
  • mytopic;{create:always,node:node:{type:topic}}
Parameters:
  • address (str) - An AMQP address.

__str__(self)
(Informal representation operator)

source code 

str(x)

Overrides: object.__str__
(inherited documentation)