org.apache.catalina.cluster.tcp: public class: SocketSender

org.apache.catalina.cluster.tcp
public class: SocketSender [javadoc | source]

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

All Implemented Interfaces:
IDataSender

Send cluster messages sync to request with only one socket.

author: Filip - Hanik

author: Peter - Rossbach

version: 1.2 -

Fields inherited from org.apache.catalina.cluster.tcp.DataSender:
sm, nrOfRequests, totalBytes, connectCounter, disconnectCounter, missingAckCounter, dataResendCounter, dataFailureCounter, doProcessingStats, processingTime, minProcessingTime, maxProcessingTime, doWaitAckStats, waitAckTime, minWaitAckTime, maxWaitAckTime, keepAliveConnectTime, keepAliveCount

Constructor:

Constructor:
public SocketSender(String domain, InetAddress host, int port) { // ------------------------------------------------------------- Constructor super(domain,host, port); } Parameters: `domain` - replication cluster domain (session domain) `host` - replication node tcp address `port` - replication node tcp port

 public SocketSender(String domain,
    InetAddress host,
    int port) {
    // ------------------------------------------------------------- Constructor
        super(domain,host, port);
}

Parameters:

domain - replication cluster domain (session domain)

host - replication node tcp address

port - replication node tcp port

Method from org.apache.catalina.cluster.tcp.SocketSender Summary:
getInfo, toString

Methods from org.apache.catalina.cluster.tcp.DataSender:
addProcessingStats, addStats, addWaitAckStats, checkKeepAlive, closeSocket, connect, createSocket, disconnect, getAckTimeout, getAddress, getAvgMessageSize, getAvgProcessingTime, getAvgWaitAckTime, getConnectCounter, getDataFailureCounter, getDataResendCounter, getDisconnectCounter, getDomain, getInfo, getKeepAliveConnectTime, getKeepAliveCount, getKeepAliveMaxRequestCount, getKeepAliveTimeout, getMaxProcessingTime, getMaxWaitAckTime, getMinProcessingTime, getMinWaitAckTime, getMissingAckCounter, getNrOfRequests, getPort, getProcessingTime, getSocket, getSocketCloseCounter, getSocketOpenCounter, getSocketOpenFailureCounter, getSuspect, getTotalBytes, getWaitAckTime, isConnected, isDoProcessingStats, isDoWaitAckStats, isMessageTransferStarted, isResend, isSuspect, isWaitForAck, openSocket, pushMessage, resetStatistics, sendMessage, setAckTimeout, setAddress, setDoProcessingStats, setDoWaitAckStats, setDomain, setKeepAliveMaxRequestCount, setKeepAliveTimeout, setPort, setResend, setSocket, setSocketConnected, setSuspect, setWaitForAck, toString, waitForAck, writeData

Methods from org.apache.catalina.cluster.tcp.DataSender:

addProcessingStats, addStats, addWaitAckStats, checkKeepAlive, closeSocket, connect, createSocket, disconnect, getAckTimeout, getAddress, getAvgMessageSize, getAvgProcessingTime, getAvgWaitAckTime, getConnectCounter, getDataFailureCounter, getDataResendCounter, getDisconnectCounter, getDomain, getInfo, getKeepAliveConnectTime, getKeepAliveCount, getKeepAliveMaxRequestCount, getKeepAliveTimeout, getMaxProcessingTime, getMaxWaitAckTime, getMinProcessingTime, getMinWaitAckTime, getMissingAckCounter, getNrOfRequests, getPort, getProcessingTime, getSocket, getSocketCloseCounter, getSocketOpenCounter, getSocketOpenFailureCounter, getSuspect, getTotalBytes, getWaitAckTime, isConnected, isDoProcessingStats, isDoWaitAckStats, isMessageTransferStarted, isResend, isSuspect, isWaitForAck, openSocket, pushMessage, resetStatistics, sendMessage, setAckTimeout, setAddress, setDoProcessingStats, setDoWaitAckStats, setDomain, setKeepAliveMaxRequestCount, setKeepAliveTimeout, setPort, setResend, setSocket, setSocketConnected, setSuspect, setWaitForAck, toString, waitForAck, writeData

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.catalina.cluster.tcp.SocketSender Detail:
public String getInfo() { return (info); } Return descriptive information about this implementation and the corresponding version number, in the format `<description>/<version>`.
public String toString() { StringBuffer buf = new StringBuffer("SocketSender["); buf.append(getAddress()).append(":").append(getPort()).append("]"); return buf.toString(); }

Method from org.apache.catalina.cluster.tcp.SocketSender Detail:

 public String getInfo() {
        return (info);
}

<description>/<version>

 public String toString() {
        StringBuffer buf = new StringBuffer("SocketSender[");
        buf.append(getAddress()).append(":").append(getPort()).append("]");
        return buf.toString();
}