public abstract class AbstractSender extends Object implements DataSender
Constructor and Description |
---|
AbstractSender() |
Modifier and Type | Method and Description |
---|---|
abstract void |
connect()
connect
|
abstract void |
disconnect()
disconnect
TODO Implement this org.apache.catalina.tribes.transport.DataSender method
|
InetAddress |
getAddress() |
int |
getAttempt() |
long |
getConnectTime() |
Member |
getDestination() |
boolean |
getDirectBuffer() |
int |
getKeepAliveCount() |
long |
getKeepAliveTime() |
int |
getMaxRetryAttempts() |
boolean |
getOoBInline() |
int |
getPort() |
int |
getRequestCount() |
int |
getRxBufSize() |
boolean |
getSoKeepAlive() |
boolean |
getSoLingerOn() |
int |
getSoLingerTime() |
boolean |
getSoReuseAddress() |
int |
getSoTrafficClass() |
boolean |
getTcpNoDelay() |
boolean |
getThrowOnFailedAck() |
long |
getTimeout() |
int |
getTxBufSize() |
int |
getUdpPort() |
int |
getUdpRxBufSize() |
int |
getUdpTxBufSize() |
boolean |
isConnected() |
boolean |
isUdpBased() |
boolean |
keepalive()
keepalive
|
void |
setAddress(InetAddress address) |
void |
setAttempt(int attempt) |
protected void |
setConnected(boolean connected) |
void |
setConnectTime(long connectTime) |
void |
setDestination(Member destination) |
void |
setDirectBuffer(boolean directBuffer) |
void |
setKeepAliveCount(int keepAliveCount) |
void |
setKeepAliveTime(long keepAliveTime) |
void |
setMaxRetryAttempts(int maxRetryAttempts) |
void |
setOoBInline(boolean ooBInline) |
void |
setPort(int port) |
void |
setRequestCount(int requestCount) |
void |
setRxBufSize(int rxBufSize) |
void |
setSoKeepAlive(boolean soKeepAlive) |
void |
setSoLingerOn(boolean soLingerOn) |
void |
setSoLingerTime(int soLingerTime) |
void |
setSoReuseAddress(boolean soReuseAddress) |
void |
setSoTrafficClass(int soTrafficClass) |
void |
setTcpNoDelay(boolean tcpNoDelay) |
void |
setThrowOnFailedAck(boolean throwOnFailedAck) |
void |
setTimeout(long timeout) |
void |
setTxBufSize(int txBufSize) |
void |
setUdpBased(boolean udpBased) |
void |
setUdpPort(int udpPort) |
void |
setUdpRxBufSize(int udpRxBufSize) |
void |
setUdpTxBufSize(int udpTxBufSize) |
static void |
transferProperties(AbstractSender from,
AbstractSender to)
transfers sender properties from one sender to another
|
public static void transferProperties(AbstractSender from, AbstractSender to)
from
- AbstractSenderto
- AbstractSenderpublic abstract void connect() throws IOException
connect
in interface DataSender
IOException
- TODO Implement this org.apache.catalina.tribes.transport.DataSender methodpublic abstract void disconnect()
disconnect
in interface DataSender
public boolean keepalive()
keepalive
in interface DataSender
protected void setConnected(boolean connected)
public boolean isConnected()
isConnected
in interface DataSender
public long getConnectTime()
getConnectTime
in interface DataSender
public Member getDestination()
public int getKeepAliveCount()
public long getKeepAliveTime()
public int getRequestCount()
getRequestCount
in interface DataSender
public int getRxBufSize()
public long getTimeout()
public int getTxBufSize()
public InetAddress getAddress()
public int getPort()
public int getMaxRetryAttempts()
public void setDirectBuffer(boolean directBuffer)
public boolean getDirectBuffer()
public int getAttempt()
public boolean getTcpNoDelay()
public boolean getSoKeepAlive()
public boolean getOoBInline()
public boolean getSoReuseAddress()
public boolean getSoLingerOn()
public int getSoLingerTime()
public int getSoTrafficClass()
public boolean getThrowOnFailedAck()
public void setKeepAliveCount(int keepAliveCount)
setKeepAliveCount
in interface DataSender
public void setKeepAliveTime(long keepAliveTime)
setKeepAliveTime
in interface DataSender
public void setRequestCount(int requestCount)
public void setRxBufSize(int rxBufSize)
setRxBufSize
in interface DataSender
public void setTimeout(long timeout)
setTimeout
in interface DataSender
public void setTxBufSize(int txBufSize)
setTxBufSize
in interface DataSender
public void setConnectTime(long connectTime)
public void setMaxRetryAttempts(int maxRetryAttempts)
public void setAttempt(int attempt)
public void setTcpNoDelay(boolean tcpNoDelay)
public void setSoKeepAlive(boolean soKeepAlive)
public void setOoBInline(boolean ooBInline)
public void setSoReuseAddress(boolean soReuseAddress)
public void setSoLingerOn(boolean soLingerOn)
public void setSoLingerTime(int soLingerTime)
public void setSoTrafficClass(int soTrafficClass)
public void setThrowOnFailedAck(boolean throwOnFailedAck)
public void setDestination(Member destination) throws UnknownHostException
UnknownHostException
public void setPort(int port)
public void setAddress(InetAddress address)
public boolean isUdpBased()
public void setUdpBased(boolean udpBased)
public int getUdpPort()
public void setUdpPort(int udpPort)
public int getUdpRxBufSize()
public void setUdpRxBufSize(int udpRxBufSize)
public int getUdpTxBufSize()
public void setUdpTxBufSize(int udpTxBufSize)
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.