Package proton :: Module _utils :: Class SyncRequestResponse

Class SyncRequestResponse

                  object --+        
                           |        
             _events.Handler --+    
                               |    
                  object --+   |    
                           |   |    
            _handlers.Acking --+    
                               |    
_handlers.IncomingMessageHandler --+
                                   |
                                  SyncRequestResponse

Implementation of the synchronous request-response (aka RPC) pattern.

Instance Methods

__init__(self, connection, address=None)
Send requests and receive responses.

source code

call(self, request)
Send a request message, wait for and return the response message.

source code

on_message(self, event)
Called when we receive a message for our receiver.

source code

Inherited from _handlers.IncomingMessageHandler: on_aborted, on_delivery, on_settled

Inherited from _events.Handler: add, handlers, on_unhandled

Inherited from _handlers.Acking: accept, reject, release, settle

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Variables
	correlation_id = `AtomicCount()`

Instance Variables
	address Address for all requests, may be None.
	connection Connection for requests and responses.

Properties
	reply_to Return the dynamic address of our receiver.
Inherited from `object`: `__class__`

Method Details

init(self, connection, address=None)
(Constructor)

source code

Send requests and receive responses. A single instance can send many requests to the same or different addresses.

Parameters:

connection - A BlockingConnection
address - Address for all requests. If not specified, each request must have the address property set. Successive messages may have different addresses.

Overrides: object.__init__

call(self, request)

source code

Send a request message, wait for and return the response message.

Parameters:

request - A proton.Message. If self.address is not set the self.address must be set and will be used.

on_message(self, event)

source code

Called when we receive a message for our receiver.

Overrides: _handlers.IncomingMessageHandler.on_message

Property Details

reply_to

Return the dynamic address of our receiver.

Get Method:: unreachable.reply_to(self) - Return the dynamic address of our receiver.

Class SyncRequestResponse

__init__(self, connection, address=None) (Constructor)

call(self, request)

on_message(self, event)

reply_to

init(self, connection, address=None)
(Constructor)