public class AsynchServiceProxy extends ServiceProxy
canReceiveLock, canSendLock
Constructor and Description |
---|
AsynchServiceProxy(int processId) |
AsynchServiceProxy(int processId,
java.lang.String configHome) |
Modifier and Type | Method and Description |
---|---|
void |
cleanAsynchRequest(int requestId) |
int |
invokeAsynchRequest(byte[] request,
int[] targets,
ReplyListener replyListener,
TOMMessageType reqType) |
int |
invokeAsynchRequest(byte[] request,
ReplyListener replyListener,
TOMMessageType reqType) |
void |
replyReceived(TOMMessage reply)
This is the method invoked by the client side communication system.
|
getInvokeTimeout, getInvokeUnorderedHashedTimeout, invoke, invokeOrdered, invokeUnordered, invokeUnorderedHashed, setInvokeTimeout, setInvokeUnorderedHashedTimeout
close, generateOperationId, generateRequestId, getCommunicationSystem, getProcessId, getSession, getViewManager, init, init, sendMessageToTargets, sendMessageToTargets, TOMulticast, TOMulticast, TOMulticast
public AsynchServiceProxy(int processId)
processId
- Replica idpublic AsynchServiceProxy(int processId, java.lang.String configHome)
processId
- Replica idconfigHome
- Configuration folderpublic int invokeAsynchRequest(byte[] request, ReplyListener replyListener, TOMMessageType reqType)
request
- replyListener
- reqType
- Request typepublic int invokeAsynchRequest(byte[] request, int[] targets, ReplyListener replyListener, TOMMessageType reqType)
request
- targets
- replyListener
- reqType
- Request typepublic void cleanAsynchRequest(int requestId)
requestId
- Requestpublic void replyReceived(TOMMessage reply)
ServiceProxy
replyReceived
in interface ReplyReceiver
replyReceived
in class ServiceProxy
reply
- The reply delivered by the client side communication system