| Methods Summary |
|---|
| public abstract void | connect()connect
|
| public abstract void | disconnect()disconnect
|
| public java.net.InetAddress | getAddress()
return address;
|
| public int | getAttempt()
return attempt;
|
| public long | getConnectTime()
return connectTime;
|
| public org.apache.catalina.tribes.Member | getDestination()
return destination;
|
| public boolean | getDirect()
return getDirectBuffer();
|
| public boolean | getDirectBuffer()
return this.directBuffer;
|
| public int | getKeepAliveCount()
return keepAliveCount;
|
| public long | getKeepAliveTime()
return keepAliveTime;
|
| public int | getMaxRetryAttempts()
return maxRetryAttempts;
|
| public boolean | getOoBInline()
return ooBInline;
|
| public int | getPort()
return port;
|
| public int | getRequestCount()
return requestCount;
|
| public int | getRxBufSize()
return rxBufSize;
|
| public boolean | getSoKeepAlive()
return soKeepAlive;
|
| public boolean | getSoLingerOn()
return soLingerOn;
|
| public int | getSoLingerTime()
return soLingerTime;
|
| public boolean | getSoReuseAddress()
return soReuseAddress;
|
| public int | getSoTrafficClass()
return soTrafficClass;
|
| public boolean | getTcpNoDelay()
return tcpNoDelay;
|
| public boolean | getThrowOnFailedAck()
return throwOnFailedAck;
|
| public long | getTimeout()
return timeout;
|
| public int | getTxBufSize()
return txBufSize;
|
| public boolean | isConnected()
return connected;
|
| public boolean | keepalive()keepalive
boolean disconnect = false;
if ( keepAliveCount >= 0 && requestCount>keepAliveCount ) disconnect = true;
else if ( keepAliveTime >= 0 && (System.currentTimeMillis()-connectTime)>keepAliveTime ) disconnect = true;
if ( disconnect ) disconnect();
return disconnect;
|
| public void | setAddress(java.net.InetAddress address)
this.address = address;
|
| public void | setAttempt(int attempt)
this.attempt = attempt;
|
| public void | setConnectTime(long connectTime)
this.connectTime = connectTime;
|
| protected void | setConnected(boolean connected)
this.connected = connected;
|
| public void | setDestination(org.apache.catalina.tribes.Member destination)
this.destination = destination;
this.address = InetAddress.getByAddress(destination.getHost());
this.port = destination.getPort();
|
| public void | setDirect(boolean direct)
setDirectBuffer(direct);
|
| public void | setDirectBuffer(boolean directBuffer)
this.directBuffer = directBuffer;
|
| public void | setKeepAliveCount(int keepAliveCount)
this.keepAliveCount = keepAliveCount;
|
| public void | setKeepAliveTime(long keepAliveTime)
this.keepAliveTime = keepAliveTime;
|
| public void | setMaxRetryAttempts(int maxRetryAttempts)
this.maxRetryAttempts = maxRetryAttempts;
|
| public void | setOoBInline(boolean ooBInline)
this.ooBInline = ooBInline;
|
| public void | setPort(int port)
this.port = port;
|
| public void | setRequestCount(int requestCount)
this.requestCount = requestCount;
|
| public void | setRxBufSize(int rxBufSize)
this.rxBufSize = rxBufSize;
|
| public void | setSoKeepAlive(boolean soKeepAlive)
this.soKeepAlive = soKeepAlive;
|
| public void | setSoLingerOn(boolean soLingerOn)
this.soLingerOn = soLingerOn;
|
| public void | setSoLingerTime(int soLingerTime)
this.soLingerTime = soLingerTime;
|
| public void | setSoReuseAddress(boolean soReuseAddress)
this.soReuseAddress = soReuseAddress;
|
| public void | setSoTrafficClass(int soTrafficClass)
this.soTrafficClass = soTrafficClass;
|
| public void | setTcpNoDelay(boolean tcpNoDelay)
this.tcpNoDelay = tcpNoDelay;
|
| public void | setThrowOnFailedAck(boolean throwOnFailedAck)
this.throwOnFailedAck = throwOnFailedAck;
|
| public void | setTimeout(long timeout)
this.timeout = timeout;
|
| public void | setTxBufSize(int txBufSize)
this.txBufSize = txBufSize;
|
| public static void | transferProperties(org.apache.catalina.tribes.transport.AbstractSender from, org.apache.catalina.tribes.transport.AbstractSender to)transfers sender properties from one sender to another
to.rxBufSize = from.rxBufSize;
to.txBufSize = from.txBufSize;
to.directBuffer = from.directBuffer;
to.keepAliveCount = from.keepAliveCount;
to.keepAliveTime = from.keepAliveTime;
to.timeout = from.timeout;
to.destination = from.destination;
to.address = from.address;
to.port = from.port;
to.maxRetryAttempts = from.maxRetryAttempts;
to.tcpNoDelay = from.tcpNoDelay;
to.soKeepAlive = from.soKeepAlive;
to.ooBInline = from.ooBInline;
to.soReuseAddress = from.soReuseAddress;
to.soLingerOn = from.soLingerOn;
to.soLingerTime = from.soLingerTime;
to.soTrafficClass = from.soTrafficClass;
to.throwOnFailedAck = from.throwOnFailedAck;
|
