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

Class BlockingConnection

source code


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

Inherited from Handler: on_unhandled

Class Variables

Inherited from Handler: handlers

Method Details

__init__(self, url, timeout=None, container=None, ssl_domain=None, heartbeat=None, **kwargs)
(Constructor)

source code 
Overrides: object.__init__
(inherited documentation)

run(self)

source code 

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