|
Apache Tomcat 6.0.35 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.catalina.tribes.transport.ReplicationTransmitter
public class ReplicationTransmitter
Transmit message to other cluster members Actual senders are created based on the replicationMode type
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 |
java.lang.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. ( deregister mbean and disconnect sender ) |
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()
Stop the channel sender |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected StringManager sm
Constructor Detail |
---|
public ReplicationTransmitter()
Method Detail |
---|
public java.lang.String getInfo()
<description>/<version>
.
public MultiPointSender getTransport()
public void setTransport(MultiPointSender transport)
public void sendMessage(ChannelMessage message, Member[] destination) throws ChannelException
sendMessage
in interface ChannelSender
message
- ChannelMessage - the message to be sentdestination
- Member[] - the destinations
ChannelException
- - if an error happens, the ChannelSender MUST report
individual send failures on a per member basis, using ChannelException.addFaultyMemberorg.apache.catalina.tribes.ClusterSender#sendMessage(org.apache.catalina.tribes.ClusterMessage, org.apache.catalina.tribes.Member)
public void start() throws java.io.IOException
start
in interface ChannelSender
IOException
- if preprocessing takes place and an error happensorg.apache.catalina.tribes.ClusterSender#start()
public void stop()
ChannelSender
stop
in interface ChannelSender
public void heartbeat()
heartbeat
in interface ChannelSender
heartbeat
in interface Heartbeat
SimpleTcpCluster#backgroundProcess()
public void add(Member member)
add
in interface ChannelSender
member
- Memberorg.apache.catalina.tribes.ClusterSender#add(org.apache.catalina.tribes.Member)
public void remove(Member member)
remove
in interface ChannelSender
member
- Memberorg.apache.catalina.tribes.ClusterSender#remove(org.apache.catalina.tribes.Member)
|
Apache Tomcat 6.0.35 | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |