org.apache.catalina.tribes.transport
Class AbstractSender

java.lang.Object
  org.apache.catalina.tribes.transport.AbstractSender

All Implemented Interfaces:

DataSender

Direct Known Subclasses:

BioSender, MultipointBioSender, NioSender, ParallelNioSender, PooledSender

public abstract class AbstractSender
extends java.lang.Object
implements DataSender

Title:

Description:

Company:

Version:

1.0

Author:

not attributable

AbstractSender

public AbstractSender()

transferProperties

public static void transferProperties(AbstractSender from,
                                      AbstractSender to)

transfers sender properties from one sender to another

Parameters:

from - AbstractSender

to - AbstractSender

connect

public abstract void connect()
                      throws java.io.IOException

Specified by:

connect in interface DataSender

Throws:

java.io.IOException

disconnect

public abstract void disconnect()

Specified by:

disconnect in interface DataSender

keepalive

public boolean keepalive()

Specified by:

keepalive in interface DataSender

setConnected

protected void setConnected(boolean connected)

isConnected

public boolean isConnected()

Specified by:

isConnected in interface DataSender

getConnectTime

public long getConnectTime()

Specified by:

getConnectTime in interface DataSender

getDestination

public Member getDestination()

getKeepAliveCount

public int getKeepAliveCount()

getKeepAliveTime

public long getKeepAliveTime()

getRequestCount

public int getRequestCount()

Specified by:

getRequestCount in interface DataSender

getRxBufSize

public int getRxBufSize()

getTimeout

public long getTimeout()

getTxBufSize

public int getTxBufSize()

getAddress

public java.net.InetAddress getAddress()

getPort

public int getPort()

getMaxRetryAttempts

public int getMaxRetryAttempts()

setDirect

public void setDirect(boolean direct)

setDirectBuffer

public void setDirectBuffer(boolean directBuffer)

getDirect

public boolean getDirect()

getDirectBuffer

public boolean getDirectBuffer()

getAttempt

public int getAttempt()

getTcpNoDelay

public boolean getTcpNoDelay()

getSoKeepAlive

public boolean getSoKeepAlive()

getOoBInline

public boolean getOoBInline()

getSoReuseAddress

public boolean getSoReuseAddress()

getSoLingerOn

public boolean getSoLingerOn()

getSoLingerTime

public int getSoLingerTime()

getSoTrafficClass

public int getSoTrafficClass()

getThrowOnFailedAck

public boolean getThrowOnFailedAck()

setKeepAliveCount

public void setKeepAliveCount(int keepAliveCount)

Specified by:

setKeepAliveCount in interface DataSender

setKeepAliveTime

public void setKeepAliveTime(long keepAliveTime)

Specified by:

setKeepAliveTime in interface DataSender

setRequestCount

public void setRequestCount(int requestCount)

setRxBufSize

public void setRxBufSize(int rxBufSize)

Specified by:

setRxBufSize in interface DataSender

setTimeout

public void setTimeout(long timeout)

Specified by:

setTimeout in interface DataSender

setTxBufSize

public void setTxBufSize(int txBufSize)

Specified by:

setTxBufSize in interface DataSender

setConnectTime

public void setConnectTime(long connectTime)

setMaxRetryAttempts

public void setMaxRetryAttempts(int maxRetryAttempts)

setAttempt

public void setAttempt(int attempt)

setTcpNoDelay

public void setTcpNoDelay(boolean tcpNoDelay)

setSoKeepAlive

public void setSoKeepAlive(boolean soKeepAlive)

setOoBInline

public void setOoBInline(boolean ooBInline)

setSoReuseAddress

public void setSoReuseAddress(boolean soReuseAddress)

setSoLingerOn

public void setSoLingerOn(boolean soLingerOn)

setSoLingerTime

public void setSoLingerTime(int soLingerTime)

setSoTrafficClass

public void setSoTrafficClass(int soTrafficClass)

setThrowOnFailedAck

public void setThrowOnFailedAck(boolean throwOnFailedAck)

setDestination

public void setDestination(Member destination)
                    throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException

setPort

public void setPort(int port)

setAddress

public void setAddress(java.net.InetAddress address)