Package proton :: Module utils :: Class BlockingConnection
[frames] | no frames]

Class BlockingConnection

source code

Handler --+
          |
         BlockingConnection

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.

Instance Methods
 
__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
 
close(self) source code
 
run(self)
Hand control over to the event loop (e.g.
source code
 
wait(self, condition, timeout=False, msg=None)
Call process until condition() is true
source code
 
on_link_remote_close(self, event) source code
 
on_connection_remote_close(self, event) source code
 
on_transport_tail_closed(self, event) source code
 
on_transport_head_closed(self, event) source code
 
on_transport_closed(self, event) source code
Method Details

run(self)

source code 

Hand control over to the event loop (e.g. if waiting indefinitely for incoming messages)