Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.apache.catalina.cluster.tcp: Javadoc index of package org.apache.catalina.cluster.tcp.


Package Samples:

org.apache.catalina.cluster.tcp

Classes:

FastAsyncSocketSender: Send cluster messages from a Message queue with only one socket. Ack and keep Alive Handling is supported. Fast Queue can limit queue size and consume all messages at queue at one block. Limit the queue lock contention under high load! With autoConnect=false at ReplicationTransmitter, you can disconnect the sender and all messages are queued. Only use this for small maintaince isuses! waitForAck=true, means that receiver ack the transfer after one minute idle time, or number of request (100) the connection is reconnected with next request. Change this for production use! default ackTimeout is 15 ...
AsyncSocketSender: Send cluster messages from a Message queue with only one socket. Ack and keep Alive Handling is supported. With autoConnect=false at ReplicationTransmitter, you can disconnect the sender and all messages are queued. Only use this for small maintaince isuses! waitForAck=true, means that receiver ack the transfer after one minute idle time, or number of request (100) the connection is reconnected with next request. Change this for production use! default ackTimeout is 15 sec: this is very low for big all session replication messages after restart a node disable keepAlive: keepAliveTimeout="-1" and ...
TcpReplicationThread: A worker thread class which can drain channels and echo-back the input. Each instance is constructed with a reference to the owning thread pool object. When started, the thread loops forever waiting to be awakened to service the channel associated with a SelectionKey object. The worker is tasked by calling its serviceChannel() method with a SelectionKey object. The serviceChannel() method stores the key reference in the thread object then calls notify() to wake it up. When the channel has been drained, the worker thread returns itself to its parent pool.
ReplicationValve: Implementation of a Valve that logs interesting contents from the specified Request (before processing) and the corresponding Response (after processing). It is especially useful in debugging problems related to headers and cookies. This Valve may be attached to any Container, depending on the granularity of the logging you wish to perform. primaryIndicator=true, then the request attribute org.apache.catalina.cluster.tcp.isPrimarySession. is set true, when request processing is at sessions primary node.
ReplicationTransmitter: Transmit message to ohter cluster members create sender from replicationMode type FIXME i18n log messages FIXME compress data depends on message type and size FIXME send very big messages at some block see FarmWarDeployer! TODO pause and resume senders
SimpleTcpCluster: A Cluster implementation using simple multicast. Responsible for setting up a cluster and provides callers with a valid multicast receiver/sender. FIXME remove install/remove/start/stop context dummys FIXME wrote testcases
IDataSenderFactory: Create DataSender for different modes. DataSender factory load mode list from org/apache/catalina/cluster/tcp/DataSenders.properties resource.
DataSender: Send cluster messages with only one socket. Ack and keep Alive Handling is supported
PooledSocketSender: Send cluster messages with a pool of sockets (25). FIXME support processing stats
Constants: Manifest constants for the org.apache.catalina.cluster.tcp package.
SocketSender: Send cluster messages sync to request with only one socket.
ReplicationListener: FIXME i18n log messages FIXME jmx support
ClusterReceiverBase: FIXME i18n log messages
IDataSender
Jdk13ReplicationListener
ThreadPool
WorkerThread
ClusterData

Home | Contact Us | Privacy Policy | Terms of Service