atavism.msgsys

Class MessageAgent.BlockingRPCState

java.lang.Object

atavism.msgsys.MessageAgent.BlockingRPCState

All Implemented Interfaces:

ResponseCallback

Enclosing class:

MessageAgent

public class MessageAgent.BlockingRPCState
extends java.lang.Object
implements ResponseCallback

This class helps handle blocking broadcast rpc. It maintains a counter, and calls through to the real callback method.

Constructor Summary

Constructors

Constructor and Description
BlockingRPCState(ResponseCallback callback)

Method Summary

Modifier and Type	Method and Description
int	getResponseCount()
void	handleResponse(ResponseMessage response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlockingRPCState

public BlockingRPCState(ResponseCallback callback)

Method Detail

handleResponse

public void handleResponse(ResponseMessage response)

Specified by:

handleResponse in interface ResponseCallback

getResponseCount

public int getResponseCount()