| java.lang.Object org.apache.catalina.tribes.group.ChannelInterceptorBase
All known Subclasses: org.apache.catalina.tribes.group.GroupChannel, org.apache.catalina.tribes.group.interceptors.TcpPingInterceptor, org.apache.catalina.tribes.group.interceptors.MessageDispatchInterceptor, org.apache.catalina.tribes.group.interceptors.NonBlockingCoordinator, org.apache.catalina.tribes.group.interceptors.TcpFailureDetector, org.apache.catalina.tribes.group.interceptors.FragmentationInterceptor, org.apache.catalina.tribes.group.interceptors.DomainFilterInterceptor, org.apache.catalina.tribes.group.interceptors.OrderInterceptor, org.apache.catalina.tribes.group.interceptors.StaticMembershipInterceptor, org.apache.catalina.tribes.group.ChannelCoordinator, org.apache.catalina.tribes.group.interceptors.GzipInterceptor, org.apache.catalina.tribes.group.interceptors.TwoPhaseCommitInterceptor, org.apache.catalina.tribes.group.interceptors.ThroughputInterceptor,
ChannelInterceptorBase | abstract public class ChannelInterceptorBase implements ChannelInterceptor(Code) | | Abstract class for the interceptor base class.
author: Filip Hanik version: $Revision: 467222 $, $Date: 2006-10-24 05:17:11 +0200 (mar., 24 oct. 2006) $ |
optionFlag | protected int optionFlag(Code) | | |
ChannelInterceptorBase | public ChannelInterceptorBase()(Code) | | |
fireInterceptorEvent | public void fireInterceptorEvent(InterceptorEvent event)(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) | | |
memberDisappeared | public void memberDisappeared(Member member)(Code) | | |
okToProcess | public boolean okToProcess(int messageFlags)(Code) | | |
setOptionFlag | public void setOptionFlag(int optionFlag)(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. |
|
|