| Methods Summary |
|---|
| public org.apache.catalina.tribes.ChannelReceiver | getClusterReceiver()
return clusterReceiver;
|
| public org.apache.catalina.tribes.ChannelSender | getClusterSender()
return clusterSender;
|
| public org.apache.catalina.tribes.Member | getLocalMember(boolean incAlive)Return the member that represents this node.
return this.getMembershipService().getLocalMember(incAlive);
|
| public org.apache.catalina.tribes.Member | getMember(org.apache.catalina.tribes.Member mbr)
return this.getMembershipService().getMember(mbr);
|
| public org.apache.catalina.tribes.Member[] | getMembers()Get all current cluster members
return this.getMembershipService().getMembers();
|
| public org.apache.catalina.tribes.MembershipService | getMembershipService()
return membershipService;
|
| public int | getOptionFlag()
return optionFlag;
|
| public boolean | hasMembers()has members
return this.getMembershipService().hasMembers();
|
| public void | heartbeat()
if ( clusterSender!=null ) clusterSender.heartbeat();
super.heartbeat();
|
| protected synchronized void | internalStart(int svc)Starts up the channel. This can be called multiple times for individual services to start
The svc parameter can be the logical or value of any constants
try {
boolean valid = false;
//make sure we don't pass down any flags that are unrelated to the bottom layer
svc = svc & Channel.DEFAULT;
if (startLevel == Channel.DEFAULT) return; //we have already started up all components
if (svc == 0 ) return;//nothing to start
if (svc == (svc & startLevel)) throw new ChannelException("Channel already started for level:"+svc);
//must start the receiver first so that we can coordinate the port it
//listens to with the local membership settings
if ( Channel.SND_RX_SEQ==(svc & Channel.SND_RX_SEQ) ) {
clusterReceiver.setMessageListener(this);
clusterReceiver.start();
//synchronize, big time FIXME
membershipService.setLocalMemberProperties(getClusterReceiver().getHost(), getClusterReceiver().getPort());
valid = true;
}
if ( Channel.SND_TX_SEQ==(svc & Channel.SND_TX_SEQ) ) {
clusterSender.start();
valid = true;
}
if ( Channel.MBR_RX_SEQ==(svc & Channel.MBR_RX_SEQ) ) {
membershipService.setMembershipListener(this);
membershipService.start(MembershipService.MBR_RX);
valid = true;
}
if ( Channel.MBR_TX_SEQ==(svc & Channel.MBR_TX_SEQ) ) {
membershipService.start(MembershipService.MBR_TX);
valid = true;
}
if ( !valid) {
throw new IllegalArgumentException("Invalid start level, valid levels are:SND_RX_SEQ,SND_TX_SEQ,MBR_TX_SEQ,MBR_RX_SEQ");
}
startLevel = (startLevel | svc);
}catch ( ChannelException cx ) {
throw cx;
}catch ( Exception x ) {
throw new ChannelException(x);
}
|
| protected synchronized void | internalStop(int svc)Shuts down the channel. This can be called multiple times for individual services to shutdown
The svc parameter can be the logical or value of any constants
try {
//make sure we don't pass down any flags that are unrelated to the bottom layer
svc = svc & Channel.DEFAULT;
if (startLevel == 0) return; //we have already stopped up all components
if (svc == 0 ) return;//nothing to stop
boolean valid = false;
if ( Channel.SND_RX_SEQ==(svc & Channel.SND_RX_SEQ) ) {
clusterReceiver.stop();
clusterReceiver.setMessageListener(null);
valid = true;
}
if ( Channel.SND_TX_SEQ==(svc & Channel.SND_TX_SEQ) ) {
clusterSender.stop();
valid = true;
}
if ( Channel.MBR_RX_SEQ==(svc & Channel.MBR_RX_SEQ) ) {
membershipService.stop(MembershipService.MBR_RX);
membershipService.setMembershipListener(null);
valid = true;
}
if ( Channel.MBR_TX_SEQ==(svc & Channel.MBR_TX_SEQ) ) {
valid = true;
membershipService.stop(MembershipService.MBR_TX);
}
if ( !valid) {
throw new IllegalArgumentException("Invalid start level, valid levels are:SND_RX_SEQ,SND_TX_SEQ,MBR_TX_SEQ,MBR_RX_SEQ");
}
startLevel = (startLevel & (~svc));
}catch ( Exception x ) {
throw new ChannelException(x);
} finally {
}
|
| public void | memberAdded(org.apache.catalina.tribes.Member member)
SenderState.getSenderState(member);
super.memberAdded(member);
|
| public void | memberDisappeared(org.apache.catalina.tribes.Member member)
SenderState.removeSenderState(member);
super.memberDisappeared(member);
|
| public void | messageReceived(org.apache.catalina.tribes.ChannelMessage msg)
if ( Logs.MESSAGES.isTraceEnabled() ) {
Logs.MESSAGES.trace("ChannelCoordinator - Received msg:" + new UniqueId(msg.getUniqueId()) + " at " +new java.sql.Timestamp(System.currentTimeMillis())+ " from "+msg.getAddress().getName());
}
super.messageReceived(msg);
|
| public void | sendMessage(org.apache.catalina.tribes.Member[] destination, org.apache.catalina.tribes.ChannelMessage msg, InterceptorPayload payload)Send a message to one or more members in the cluster
if ( destination == null ) destination = membershipService.getMembers();
clusterSender.sendMessage(msg,destination);
if ( Logs.MESSAGES.isTraceEnabled() ) {
Logs.MESSAGES.trace("ChannelCoordinator - Sent msg:" + new UniqueId(msg.getUniqueId()) + " at " +new java.sql.Timestamp(System.currentTimeMillis())+ " to "+Arrays.toNameString(destination));
}
|
| public void | setClusterReceiver(org.apache.catalina.tribes.ChannelReceiver clusterReceiver)
if ( clusterReceiver != null ) {
this.clusterReceiver = clusterReceiver;
this.clusterReceiver.setMessageListener(this);
} else {
if (this.clusterReceiver!=null ) this.clusterReceiver.setMessageListener(null);
this.clusterReceiver = null;
}
|
| public void | setClusterSender(org.apache.catalina.tribes.ChannelSender clusterSender)
this.clusterSender = clusterSender;
|
| public void | setMembershipService(org.apache.catalina.tribes.MembershipService membershipService)
this.membershipService = membershipService;
this.membershipService.setMembershipListener(this);
|
| public void | setOptionFlag(int flag)optionFlag=flag;
|
| public void | start(int svc)Starts up the channel. This can be called multiple times for individual services to start
The svc parameter can be the logical or value of any constants
this.internalStart(svc);
|
| public void | stop(int svc)Shuts down the channel. This can be called multiple times for individual services to shutdown
The svc parameter can be the logical or value of any constants
this.internalStop(svc);
|
