org.apache.catalina.tribes.transport

Class ReplicationTransmitter

public class ReplicationTransmitter extends Object implements ChannelSender

Transmit message to other cluster members Actual senders are created based on the replicationMode type

Version: $Revision: 532800 $ $Date: 2007-04-26 18:52:29 +0200 (Thu, 26 Apr 2007) $

Author: Filip Hanik

Field Summary
protected StringManager	sm The string manager for this package.

Constructor Summary
	ReplicationTransmitter()

Method Summary
void	add(Member member) add new cluster member and create sender ( s. replicationMode) transfer current properties to sender
String	getInfo() Return descriptive information about this implementation and the corresponding version number, in the format `<description>/<version>`.
MultiPointSender	getTransport()
void	heartbeat() Call transmitter to check for sender socket status
void	remove(Member member) remove sender from transmitter.
void	sendMessage(ChannelMessage message, Member[] destination) Send data to one member
void	setTransport(MultiPointSender transport)
void	start() start the sender and register transmitter mbean
void	stop()

Field Detail

sm

protected StringManager sm

The string manager for this package.

Constructor Detail

ReplicationTransmitter

public ReplicationTransmitter()

Method Detail

add

public void add(Member member)

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()

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

getTransport

public MultiPointSender getTransport()

heartbeat

public void heartbeat()

Call transmitter to check for sender socket status

See Also: SimpleTcpCluster#backgroundProcess()

remove

public void remove(Member member)

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)

Send data to one member

See Also: org.apache.catalina.tribes.ClusterSender#sendMessage(org.apache.catalina.tribes.ClusterMessage, org.apache.catalina.tribes.Member)

setTransport

public void setTransport(MultiPointSender transport)

start

public void start()

start the sender and register transmitter mbean

See Also: org.apache.catalina.tribes.ClusterSender#start()

stop

public void stop()

Copyright © 2000-2011 Apache Software Foundation. All Rights Reserved.