| |
|
| java.lang.Object org.apache.catalina.tribes.transport.ReplicationTransmitter
ReplicationTransmitter | public class ReplicationTransmitter implements ChannelSender(Code) | | Transmit message to other cluster members
Actual senders are created based on the replicationMode
type
author: Filip Hanik version: $Revision: 532800 $ $Date: 2007-04-26 18:52:29 +0200 (jeu., 26 avr. 2007) $ |
Field Summary | |
protected StringManager | sm The string manager for this package. |
ReplicationTransmitter | public ReplicationTransmitter()(Code) | | |
add | public synchronized void add(Member member)(Code) | | add new cluster member and create sender ( s. replicationMode) transfer
current properties to sender
See Also: org.apache.catalina.tribes.ClusterSender.add(org.apache.catalina.tribes.Member) |
getInfo | public String getInfo()(Code) | | Return descriptive information about this implementation and the
corresponding version number, in the format
<description>/<version> .
|
heartbeat | public void heartbeat()(Code) | | Call transmitter to check for sender socket status
See Also: SimpleTcpCluster.backgroundProcess |
remove | public synchronized void remove(Member member)(Code) | | remove sender from transmitter. ( deregister mbean and disconnect sender )
See Also: org.apache.catalina.tribes.ClusterSender.remove(org.apache.catalina.tribes.Member) |
sendMessage | public void sendMessage(ChannelMessage message, Member[] destination) throws ChannelException(Code) | | Send data to one member
See Also: org.apache.catalina.tribes.ClusterSender.sendMessage(org.apache.catalina.tribes.ClusterMessageorg.apache.catalina.tribes.Member) |
start | public void start() throws java.io.IOException(Code) | | start the sender and register transmitter mbean
See Also: org.apache.catalina.tribes.ClusterSender.start |
stop | public synchronized void stop()(Code) | | |
|
|
|