File	Doc	Category	Size	Date	Package
ChannelInterceptorBase.java	API Doc	Apache Tomcat 6.0.14	5683	Fri Jul 20 04:20:32 BST 2007	org.apache.catalina.tribes.group

ChannelInterceptorBase

• java.lang.Object

Fields Summary
protected static org.apache.juli.logging.Log	log
private org.apache.catalina.tribes.ChannelInterceptor	next
private org.apache.catalina.tribes.ChannelInterceptor	previous
protected int	optionFlag

Constructors Summary
public ChannelInterceptorBase()

Methods Summary
public boolean	accept(org.apache.catalina.tribes.ChannelMessage msg) return true;
public void	fireInterceptorEvent(InterceptorEvent event) //empty operation
public org.apache.catalina.tribes.Member	getLocalMember(boolean incAlive) Return the member that represents this node. return Member if ( getNext()!=null ) return getNext().getLocalMember(incAlive); else return null;
public org.apache.catalina.tribes.Member	getMember(org.apache.catalina.tribes.Member mbr) param mbr Member return Member if ( getNext()!=null) return getNext().getMember(mbr); else return null;
public org.apache.catalina.tribes.Member[]	getMembers() Get all current cluster members return all members or empty array if ( getNext()!=null ) return getNext().getMembers(); else return null;
public final org.apache.catalina.tribes.ChannelInterceptor	getNext() return next;
public int	getOptionFlag() return optionFlag;
public final org.apache.catalina.tribes.ChannelInterceptor	getPrevious() return previous;
public boolean	hasMembers() has members if ( getNext()!=null )return getNext().hasMembers(); else return false;
public void	heartbeat() if (getNext() != null) getNext().heartbeat();
public void	memberAdded(org.apache.catalina.tribes.Member member) //notify upwards if (getPrevious() != null) getPrevious().memberAdded(member);
public void	memberDisappeared(org.apache.catalina.tribes.Member member) //notify upwards if (getPrevious() != null) getPrevious().memberDisappeared(member);
public void	messageReceived(org.apache.catalina.tribes.ChannelMessage msg) if (getPrevious() != null) getPrevious().messageReceived(msg);
public boolean	okToProcess(int messageFlags) if (this.optionFlag == 0 ) return true; return ((optionFlag&messageFlags) == optionFlag);
public void	sendMessage(org.apache.catalina.tribes.Member[] destination, org.apache.catalina.tribes.ChannelMessage msg, InterceptorPayload payload) if (getNext() != null) getNext().sendMessage(destination, msg, payload);
public final void	setNext(org.apache.catalina.tribes.ChannelInterceptor next) this.next = next;
public void	setOptionFlag(int optionFlag) this.optionFlag = optionFlag;
public final void	setPrevious(org.apache.catalina.tribes.ChannelInterceptor previous) this.previous = previous;
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 param 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. if ( getNext()!=null ) getNext().start(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 param 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. if (getNext() != null) getNext().stop(svc);