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 StringManagersm
The string manager for this package.
Constructor Summary
ReplicationTransmitter()
Method Summary
voidadd(Member member)
add new cluster member and create sender ( s. replicationMode) transfer current properties to sender
StringgetInfo()
Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version>.
MultiPointSendergetTransport()
voidheartbeat()
Call transmitter to check for sender socket status
voidremove(Member member)
remove sender from transmitter.
voidsendMessage(ChannelMessage message, Member[] destination)
Send data to one member
voidsetTransport(MultiPointSender transport)
voidstart()
start the sender and register transmitter mbean
voidstop()

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.