This class represents a connection to an AMQP broker.
|
|
__init__(self,
ssn,
topicCb,
replyCb,
exceptionCb,
cbContext,
_detlife=0)
Given a channel on an established AMQP broker connection, this method
opens a session and performs all of the declarations and bindings
needed to participate in the management protocol. |
|
|
|
|
| setBrokerInfo(self,
data) |
|
|
|
|
|
|
|
topicCb(self,
msg)
Receive messages via the topic queue on this channel. |
|
|
|
|
replyCb(self,
msg)
Receive messages via the reply queue on this channel. |
|
|
|
|
|
|
|
| send(self,
exchange,
msg) |
|
|
|
|
message(self,
body,
routing_key='broker') |
|
|