A synchronous style connection wrapper.
This object's implementation uses OS resources. To ensure they are
released when the object is no longer in use, make sure that object
operations are enclosed in a try block and that close() is always
executed on exit.
|
__init__(self,
url,
timeout=None,
container=None,
ssl_domain=None,
heartbeat=None,
**kwargs)
x.__init__(...) initializes x; see help(type(x)) for signature |
source code
|
|
|
create_sender(self,
address,
handler=None,
name=None,
options=None) |
source code
|
|
|
create_receiver(self,
address,
credit=None,
dynamic=False,
handler=None,
name=None,
options=None) |
source code
|
|
|
|
|
|
|
wait(self,
condition,
timeout=False,
msg=None)
Call process until condition() is true |
source code
|
|
|
|
|
|
|
|
|
|
|
|
Inherited from _events.Handler :
handlers ,
on_unhandled
Inherited from object :
__delattr__ ,
__format__ ,
__getattribute__ ,
__hash__ ,
__new__ ,
__reduce__ ,
__reduce_ex__ ,
__repr__ ,
__setattr__ ,
__sizeof__ ,
__str__ ,
__subclasshook__
|