org.apache.catalina.cluster.tcp
Class SocketSender

java.lang.Object
  org.apache.catalina.cluster.tcp.DataSender
      org.apache.catalina.cluster.tcp.SocketSender

All Implemented Interfaces:

IDataSender

public class SocketSender

extends DataSender

Send cluster messages sync to request with only one socket.

Version:

1.2

Author:

Filip Hanik, Peter Rossbach

Field Summary

Fields inherited from class org.apache.catalina.cluster.tcp.DataSender

connectCounter, createTime, dataFailureCounter, dataResendCounter, disconnectCounter, doProcessingStats, doWaitAckStats, keepAliveConnectTime, keepAliveCount, maxProcessingTime, maxWaitAckTime, minProcessingTime, minWaitAckTime, missingAckCounter, nrOfRequests, processingTime, sm, totalBytes, waitAckTime

Constructor Summary

SocketSender(java.lang.String domain, java.net.InetAddress host, int port)

SocketSender(java.lang.String domain, java.net.InetAddress host, int port, SenderState state)

Method Summary

java.lang.String	getInfo() Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version>.
java.lang.String	toString() Name of this SockerSender

Methods inherited from class org.apache.catalina.cluster.tcp.DataSender

addProcessingStats, addStats, addWaitAckStats, checkKeepAlive, closeSocket, connect, createSocket, disconnect, getAckTimeout, getAddress, getAvgMessageSize, getAvgProcessingTime, getAvgWaitAckTime, getConnectCounter, getCreateTime, getDataFailureCounter, getDataResendCounter, getDisconnectCounter, getDomain, getKeepAliveConnectTime, getKeepAliveCount, getKeepAliveMaxRequestCount, getKeepAliveTimeout, getMaxProcessingTime, getMaxWaitAckTime, getMinProcessingTime, getMinWaitAckTime, getMissingAckCounter, getNrOfRequests, getPort, getProcessingTime, getRxBufSize, getSenderState, getSocket, getSocketCloseCounter, getSocketOpenCounter, getSocketOpenFailureCounter, getSoLingerTime, getSoTrafficClass, getSuspect, getTimeout, getTotalBytes, getTxBufSize, getWaitAckTime, isConnected, isDoProcessingStats, isDoWaitAckStats, isMessageTransferStarted, isOoBInline, isResend, isSoKeepAlive, isSoLingerOn, isSoReuseAddress, isSuspect, isTcpNoDelay, isWaitForAck, openSocket, pushMessage, resetStatistics, sendMessage, setAckTimeout, setAddress, setDomain, setDoProcessingStats, setDoWaitAckStats, setKeepAliveMaxRequestCount, setKeepAliveTimeout, setOoBInline, setPort, setResend, setRxBufSize, setSocket, setSocketConnected, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setSuspect, setTcpNoDelay, setTimeout, setTxBufSize, setWaitForAck, waitForAck, writeData

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SocketSender

public SocketSender(java.lang.String domain,
                    java.net.InetAddress host,
                    int port)

Parameters:

domain - replication cluster domain (session domain)

host - replication node tcp address

port - replication node tcp port

SocketSender

public SocketSender(java.lang.String domain,
                    java.net.InetAddress host,
                    int port,
                    SenderState state)

Method Detail

getInfo

public java.lang.String getInfo()

Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version>.

Overrides:

getInfo in class DataSender

toString

public java.lang.String toString()

Description copied from class: DataSender

Name of this SockerSender

Overrides:

toString in class DataSender