File	Doc	Category	Size	Date	Package
ReplicationTransmitter.java	API Doc	Apache Tomcat 6.0.14	4474	Fri Jul 20 04:20:32 BST 2007	org.apache.catalina.tribes.transport

ReplicationTransmitter

• java.lang.Object

Fields Summary
private static org.apache.juli.logging.Log	log
private static final String	info The descriptive information about this implementation.
protected org.apache.catalina.tribes.util.StringManager	sm The string manager for this package.
private MultiPointSender	transport

Constructors Summary
public ReplicationTransmitter()

Methods Summary
public synchronized void	add(org.apache.catalina.tribes.Member member) add new cluster member and create sender ( s. replicationMode) transfer current properties to sender see org.apache.catalina.tribes.ClusterSender#add(org.apache.catalina.tribes.Member) getTransport().add(member);
public java.lang.String	getInfo() Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version>. return (info);
public MultiPointSender	getTransport() return transport;
public void	heartbeat() Call transmitter to check for sender socket status see SimpleTcpCluster#backgroundProcess() if (getTransport()!=null) getTransport().keepalive();
public synchronized void	remove(org.apache.catalina.tribes.Member member) remove sender from transmitter. ( deregister mbean and disconnect sender ) see org.apache.catalina.tribes.ClusterSender#remove(org.apache.catalina.tribes.Member) getTransport().remove(member);
public void	sendMessage(org.apache.catalina.tribes.ChannelMessage message, org.apache.catalina.tribes.Member[] destination) Send data to one member see org.apache.catalina.tribes.ClusterSender#sendMessage(org.apache.catalina.tribes.ClusterMessage, org.apache.catalina.tribes.Member) MultiPointSender sender = getTransport(); sender.sendMessage(destination,message);
public void	setTransport(MultiPointSender transport) this.transport = transport;
public void	start() start the sender and register transmitter mbean see org.apache.catalina.tribes.ClusterSender#start() getTransport().connect();
public synchronized void	stop() getTransport().disconnect();