private class MessageTrackerHubService.MessageTrackerCallableClient extends java.lang.Object implements CallableClient
| Modifier and Type | Field and Description |
|---|---|
private CallableClient |
base_ |
private MessageTrackerHubService.MessageTrackerHubClient |
client_ |
| Constructor and Description |
|---|
MessageTrackerCallableClient(CallableClient base,
MessageTrackerHubService.MessageTrackerHubClient client)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
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 MessageTrackerHubService.MessageTrackerHubClient client_
MessageTrackerCallableClient(CallableClient base, MessageTrackerHubService.MessageTrackerHubClient client)
base - callable on which this one is basedclient - hub client for which this receiver is operatingpublic void receiveCall(java.lang.String senderId,
java.lang.String msgId,
Message msg)
throws SampException
CallableClientreply
method at some future point.receiveCall in interface CallableClientsenderId - public ID of sending clientmsgId - message identifier for later use with replymsg - messageSampExceptionpublic void receiveNotification(java.lang.String senderId,
Message msg)
throws SampException
CallableClientreceiveNotification in interface CallableClientsenderId - public ID of sending clientmsg - messageSampExceptionpublic void receiveResponse(java.lang.String responderId,
java.lang.String msgTag,
Response response)
throws java.lang.Exception
CallableClientreceiveResponse in interface CallableClientresponderId - public ID of responding clientmsgTag - client-defined tag labelling previously-sent messageresponse - returned response objectjava.lang.Exception