|
| |
|
| java.lang.Object
 org.apache.catalina.tribes.group.ChannelInterceptorBase
org.apache.catalina.tribes.group.ChannelCoordinator
| ChannelCoordinator | | public class ChannelCoordinator extends ChannelInterceptorBase implements MessageListener(Code) | | The channel coordinator object coordinates the membership service,
the sender and the receiver.
This is the last interceptor in the chain.
author:
Filip Hanik
version:
$Revision: 532943 $, $Date: 2007-04-27 05:14:58 +0200 (ven., 27 avr. 2007) $ |
| optionFlag | | protected int optionFlag(Code) | | |
| ChannelCoordinator | | public ChannelCoordinator()(Code) | | |
| getLocalMember | | public Member getLocalMember(boolean incAlive)(Code) | | Return the member that represents this node.
Member |
| getMembers | | public Member[] getMembers()(Code) | | Get all current cluster members
all members or empty array |
| getOptionFlag | | public int getOptionFlag()(Code) | | |
| hasMembers | | public boolean hasMembers()(Code) | | has members
|
| heartbeat | | public void heartbeat()(Code) | | |
| internalStart | | protected synchronized void internalStart(int svc) throws ChannelException(Code) | | 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
Parameters:
svc - int value of
DEFAULT - will start all services
MBR_RX_SEQ - starts the membership receiver
MBR_TX_SEQ - starts the membership broadcaster
SND_TX_SEQ - starts the replication transmitter
SND_RX_SEQ - starts the replication receiver
throws:
ChannelException - if a startup error occurs or the service is already started. |
| internalStop | | protected synchronized void internalStop(int svc) throws ChannelException(Code) | | 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
Parameters:
svc - int value of
DEFAULT - will shutdown all services
MBR_RX_SEQ - starts the membership receiver
MBR_TX_SEQ - starts the membership broadcaster
SND_TX_SEQ - starts the replication transmitter
SND_RX_SEQ - starts the replication receiver
throws:
ChannelException - if a startup error occurs or the service is already started. |
| memberDisappeared | | public void memberDisappeared(Member member)(Code) | | |
| sendMessage | | public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException(Code) | | Send a message to one or more members in the cluster
Parameters:
destination - Member[] - the destinations, null or zero length means all
Parameters:
msg - ClusterMessage - the message to send
Parameters:
options - int - sender options, see class documentation ClusterMessage[] - the replies from the members, if any. |
| setOptionFlag | | public void setOptionFlag(int flag)(Code) | | |
| start | | public void start(int svc) throws ChannelException(Code) | | 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
Parameters:
svc - int value of
DEFAULT - will start all services
MBR_RX_SEQ - starts the membership receiver
MBR_TX_SEQ - starts the membership broadcaster
SND_TX_SEQ - starts the replication transmitter
SND_RX_SEQ - starts the replication receiver
throws:
ChannelException - if a startup error occurs or the service is already started. |
| stop | | public void stop(int svc) throws ChannelException(Code) | | 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
Parameters:
svc - int value of
DEFAULT - will shutdown all services
MBR_RX_SEQ - stops the membership receiver
MBR_TX_SEQ - stops the membership broadcaster
SND_TX_SEQ - stops the replication transmitter
SND_RX_SEQ - stops the replication receiver
throws:
ChannelException - if a startup error occurs or the service is already started. |
|
|
|