private class MessageTrackerHubConnector.MessageTrackerCallableClient extends java.lang.Object implements CallableClient
Modifier and Type | Field and Description |
---|---|
private CallableClient |
base_ |
private MessageTrackerHubConnector.MessageTrackerHubConnection |
connection_ |
Constructor and Description |
---|
MessageTrackerCallableClient(CallableClient base,
MessageTrackerHubConnector.MessageTrackerHubConnection connection)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
private Client |
getSelfClient()
Returns a Client object for use in Transmission objects
which represents this connection's owner.
|
void |
receiveCall(java.lang.String senderId,
java.lang.String msgId,
Message msg)
Receives a message for which a response is required.
|
void |
receiveNotification(java.lang.String senderId,
Message msg)
Receives a message for which no response is required.
|
void |
receiveResponse(java.lang.String responderId,
java.lang.String msgTag,
Response response)
Receives a response to a message previously sent by this client.
|
private final CallableClient base_
private final MessageTrackerHubConnector.MessageTrackerHubConnection connection_
MessageTrackerCallableClient(CallableClient base, MessageTrackerHubConnector.MessageTrackerHubConnection connection)
base
- base callableconnection
- hub connectionprivate Client getSelfClient()
public void receiveCall(java.lang.String senderId, java.lang.String msgId, Message msg) throws java.lang.Exception
CallableClient
reply
method at some future point.receiveCall
in interface CallableClient
senderId
- public ID of sending clientmsgId
- message identifier for later use with replymsg
- messagejava.lang.Exception
public void receiveNotification(java.lang.String senderId, Message msg) throws java.lang.Exception
CallableClient
receiveNotification
in interface CallableClient
senderId
- public ID of sending clientmsg
- messagejava.lang.Exception
public void receiveResponse(java.lang.String responderId, java.lang.String msgTag, Response response) throws java.lang.Exception
CallableClient
receiveResponse
in interface CallableClient
responderId
- public ID of responding clientmsgTag
- client-defined tag labelling previously-sent messageresponse
- returned response objectjava.lang.Exception