org.apache.catalina.tribes.group
public abstract class ChannelInterceptorBase extends Object implements ChannelInterceptor
Version: $Revision: 467222 $, $Date: 2006-10-24 05:17:11 +0200 (Tue, 24 Oct 2006) $
Field Summary | |
---|---|
protected static Log | log |
protected int | optionFlag |
Constructor Summary | |
---|---|
ChannelInterceptorBase() |
Method Summary | |
---|---|
boolean | accept(ChannelMessage msg) |
void | fireInterceptorEvent(InterceptorEvent event) |
Member | getLocalMember(boolean incAlive)
Return the member that represents this node.
|
Member | getMember(Member mbr) |
Member[] | getMembers()
Get all current cluster members |
ChannelInterceptor | getNext() |
int | getOptionFlag() |
ChannelInterceptor | getPrevious() |
boolean | hasMembers()
has members |
void | heartbeat() |
void | memberAdded(Member member) |
void | memberDisappeared(Member member) |
void | messageReceived(ChannelMessage msg) |
boolean | okToProcess(int messageFlags) |
void | sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) |
void | setNext(ChannelInterceptor next) |
void | setOptionFlag(int optionFlag) |
void | setPrevious(ChannelInterceptor previous) |
void | start(int svc)
Starts up the channel. |
void | stop(int svc)
Shuts down the channel. |
Returns: Member
Parameters: mbr Member
Returns: Member
Returns: all members or empty array
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.
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.