this.maxTimeoutUnit = maxTimeoutUnit;
}
/**
- * @param rpcPool
+ * @param rpcPool executor service pool for rpc
*/
public void setRpcPool(ListeningExecutorService rpcPool) {
this.rpcPool = rpcPool;
}
/**
- * @param messageSpy
+ * @param messageSpy the message spy
*/
public void setMessageSpy(MessageSpy<DataContainer> messageSpy) {
this.messageSpy = messageSpy;