| Methods Summary |
|---|
| public void | add(org.apache.catalina.tribes.Member member)
// no op, senders created upon demans
|
| public synchronized void | connect()
//do nothing, happens in the socket sender itself
queue.open();
setConnected(true);
|
| public synchronized void | disconnect()
queue.close();
setConnected(false);
|
| public int | getInPoolSize()
return queue.getInPoolSize();
|
| public int | getInUsePoolSize()
return queue.getInUsePoolSize();
|
| public abstract DataSender | getNewDataSender()
|
| public int | getPoolSize()
return poolSize;
|
| public DataSender | getSender()
return queue.getSender(getTimeout());
|
| public boolean | keepalive()
//do nothing, the pool checks on every return
return (queue==null)?false:queue.checkIdleKeepAlive();
|
| public void | remove(org.apache.catalina.tribes.Member member)
//no op for now, should not cancel out any keys
//can create serious sync issues
//all TCP connections are cleared out through keepalive
//and if remote node disappears
|
| public void | returnSender(DataSender sender)
sender.keepalive();
queue.returnSender(sender);
|
| public void | setPoolSize(int poolSize)
this.poolSize = poolSize;
queue.setLimit(poolSize);
|
