Class AbstractSender

java.lang.Object
org.apache.catalina.tribes.transport.AbstractSender
All Implemented Interfaces:
DataSender
Direct Known Subclasses:
NioSender, ParallelNioSender, PooledSender

public abstract class AbstractSender extends Object implements DataSender
  • Constructor Details

    • AbstractSender

      public AbstractSender()
  • Method Details

    • 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 IOException
      connect
      Specified by:
      connect in interface DataSender
      Throws:
      IOException - TODO Implement this org.apache.catalina.tribes.transport.DataSender method
    • disconnect

      public abstract void disconnect()
      disconnect TODO Implement this org.apache.catalina.tribes.transport.DataSender method
      Specified by:
      disconnect in interface DataSender
    • keepalive

      public boolean keepalive()
      keepalive
      Specified by:
      keepalive in interface DataSender
      Returns:
      boolean TODO Implement this org.apache.catalina.tribes.transport.DataSender method
    • 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 InetAddress getAddress()
    • getPort

      public int getPort()
    • getMaxRetryAttempts

      public int getMaxRetryAttempts()
    • setDirectBuffer

      public void setDirectBuffer(boolean directBuffer)
    • 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 UnknownHostException
      Throws:
      UnknownHostException
    • setPort

      public void setPort(int port)
    • setAddress

      public void setAddress(InetAddress address)
    • isUdpBased

      public boolean isUdpBased()
    • setUdpBased

      public void setUdpBased(boolean udpBased)
    • getUdpPort

      public int getUdpPort()
    • setUdpPort

      public void setUdpPort(int udpPort)
    • getUdpRxBufSize

      public int getUdpRxBufSize()
    • setUdpRxBufSize

      public void setUdpRxBufSize(int udpRxBufSize)
    • getUdpTxBufSize

      public int getUdpTxBufSize()
    • setUdpTxBufSize

      public void setUdpTxBufSize(int udpTxBufSize)