A representation of the AMQP concept of a 'container', which loosely
speaking is something that establishes links to or from another
container, over which messages are transfered. This is an extension to
the Reactor class that adds convenience methods for creating connections
and sender- or receiver- links.
|
__init__(self,
*handlers,
**kwargs)
x.__init__(...) initializes x; see help(type(x)) for signature |
source code
|
|
|
connect(self,
url=None,
urls=None,
address=None,
handler=None,
reconnect=None,
heartbeat=None,
ssl_domain=None,
**kwargs)
Initiates the establishment of an AMQP connection. |
source code
|
|
|
create_sender(self,
context,
target=None,
source=None,
name=None,
handler=None,
tags=None,
options=None)
Initiates the establishment of a link over which messages can be
sent. |
source code
|
|
|
create_receiver(self,
context,
source=None,
target=None,
name=None,
dynamic=False,
handler=None,
options=None)
Initiates the establishment of a link over which messages can be
received (aka a subscription). |
source code
|
|
|
declare_transaction(self,
context,
handler=None,
settle_before_discharge=False) |
source code
|
|
|
listen(self,
url,
ssl_domain=None)
Initiates a server socket, accepting incoming AMQP connections on the
interface and port specified. |
source code
|
|
|
|
Inherited from Reactor :
acceptor ,
connection ,
connection_to_host ,
get_connection_address ,
mark ,
on_error ,
on_error_delegate ,
process ,
push_event ,
quiesced ,
run ,
schedule ,
selectable ,
set_connection_host ,
start ,
stop ,
update ,
wakeup ,
yield_
Inherited from _wrapper.Wrapper :
__del__ ,
__delattr__ ,
__eq__ ,
__getattr__ ,
__hash__ ,
__ne__ ,
__repr__ ,
__setattr__
Inherited from object :
__format__ ,
__getattribute__ ,
__new__ ,
__reduce__ ,
__reduce_ex__ ,
__sizeof__ ,
__str__ ,
__subclasshook__
|