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) |
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
|
|
|
|
|
|
|
|
|
|
|
|