public class RequestResponseCoordinator
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected HashMap |
map_msgId_2_entry
message id
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
containsMsgId(URI msgId)
Returns
true if msgId is managed by the request response
coordinator, else false. |
static RequestResponseCoordinator |
getInstance()
Get singleton instance of request response coordinator.
|
ResponseHandler |
getResponseHandlerAndUpdateConnectionInfo(Message msg,
ConnectionInfo connectionInfo)
Handle response message.
|
void |
registerResponseCallback(Message msg,
ResponseCallback callback,
ConnectionInfo connectionInfo,
long timeUntilTimeout,
AttributedURI optionalMessageID)
Registers callback for an outgoing request message.
|
protected final HashMap map_msgId_2_entry
public static RequestResponseCoordinator getInstance()
public void registerResponseCallback(Message msg, ResponseCallback callback, ConnectionInfo connectionInfo, long timeUntilTimeout, AttributedURI optionalMessageID)
msg - - the request message.callback - - callback for responses, faults or timeouts.timeUntilTimeout - public ResponseHandler getResponseHandlerAndUpdateConnectionInfo(Message msg, ConnectionInfo connectionInfo)
msg - connectionInfo - true - if message is exclusively handled by RequestResponseCoordinatorpublic boolean containsMsgId(URI msgId)
true if msgId is managed by the request response
coordinator, else false.msgId - The msg id to look for.true if msgId is managed by the request response coordinator, else
false.