org.codehaus.wadi.tribes
Class WadiMemberInterceptor
java.lang.Object
org.apache.catalina.tribes.group.ChannelInterceptorBase
org.codehaus.wadi.tribes.WadiMemberInterceptor
- All Implemented Interfaces:
- org.apache.catalina.tribes.ChannelInterceptor, org.apache.catalina.tribes.Heartbeat, org.apache.catalina.tribes.MembershipListener
public class WadiMemberInterceptor
- extends org.apache.catalina.tribes.group.ChannelInterceptorBase
Title:
Description:
Copyright: Copyright (c) 2006
Company:
- Version:
- 1.0
- Author:
- not attributable
Nested classes/interfaces inherited from interface org.apache.catalina.tribes.ChannelInterceptor |
org.apache.catalina.tribes.ChannelInterceptor.InterceptorEvent |
Fields inherited from class org.apache.catalina.tribes.group.ChannelInterceptorBase |
log, optionFlag |
Method Summary |
int |
addAndGetInstanceCounter(int val)
|
org.apache.catalina.tribes.Member |
getLocalMember(boolean incAlive)
|
org.apache.catalina.tribes.Member |
getMember(org.apache.catalina.tribes.Member mbr)
|
org.apache.catalina.tribes.Member[] |
getMembers()
|
void |
memberAdded(org.apache.catalina.tribes.Member member)
|
void |
memberDisappeared(org.apache.catalina.tribes.Member member)
|
void |
messageReceived(org.apache.catalina.tribes.ChannelMessage msg)
|
protected org.apache.catalina.tribes.Member[] |
reverse(org.apache.catalina.tribes.Member[] mbrs)
|
protected static org.apache.catalina.tribes.Member |
reverseWrap(TribesPeer peer)
|
void |
sendMessage(org.apache.catalina.tribes.Member[] destination,
org.apache.catalina.tribes.ChannelMessage msg,
org.apache.catalina.tribes.group.InterceptorPayload payload)
|
void |
start(int svc)
|
void |
stop(int svc)
|
static TribesPeer |
wrap(org.apache.catalina.tribes.Member mbr)
|
Methods inherited from class org.apache.catalina.tribes.group.ChannelInterceptorBase |
accept, fireInterceptorEvent, getNext, getOptionFlag, getPrevious, hasMembers, heartbeat, okToProcess, setNext, setOptionFlag, setPrevious |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
map
protected static java.util.HashMap map
reversemap
protected static java.util.HashMap reversemap
instanceCounters
protected static int instanceCounters
startLevel
protected int startLevel
comp
protected WadiMemberInterceptor.MemberComparator comp
memberNotification
protected boolean memberNotification
memberMutex
protected java.lang.Object memberMutex
WadiMemberInterceptor
public WadiMemberInterceptor()
addAndGetInstanceCounter
public int addAndGetInstanceCounter(int val)
memberAdded
public void memberAdded(org.apache.catalina.tribes.Member member)
- Specified by:
memberAdded
in interface org.apache.catalina.tribes.MembershipListener
- Overrides:
memberAdded
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
messageReceived
public void messageReceived(org.apache.catalina.tribes.ChannelMessage msg)
- Specified by:
messageReceived
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
messageReceived
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
sendMessage
public void sendMessage(org.apache.catalina.tribes.Member[] destination,
org.apache.catalina.tribes.ChannelMessage msg,
org.apache.catalina.tribes.group.InterceptorPayload payload)
throws org.apache.catalina.tribes.ChannelException
- Specified by:
sendMessage
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
sendMessage
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
- Throws:
org.apache.catalina.tribes.ChannelException
reverse
protected org.apache.catalina.tribes.Member[] reverse(org.apache.catalina.tribes.Member[] mbrs)
memberDisappeared
public void memberDisappeared(org.apache.catalina.tribes.Member member)
- Specified by:
memberDisappeared
in interface org.apache.catalina.tribes.MembershipListener
- Overrides:
memberDisappeared
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
getMembers
public org.apache.catalina.tribes.Member[] getMembers()
- Specified by:
getMembers
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
getMembers
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
getMember
public org.apache.catalina.tribes.Member getMember(org.apache.catalina.tribes.Member mbr)
- Specified by:
getMember
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
getMember
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
getLocalMember
public org.apache.catalina.tribes.Member getLocalMember(boolean incAlive)
- Specified by:
getLocalMember
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
getLocalMember
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
wrap
public static TribesPeer wrap(org.apache.catalina.tribes.Member mbr)
reverseWrap
protected static org.apache.catalina.tribes.Member reverseWrap(TribesPeer peer)
start
public void start(int svc)
throws org.apache.catalina.tribes.ChannelException
- Specified by:
start
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
start
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
- Throws:
org.apache.catalina.tribes.ChannelException
stop
public void stop(int svc)
throws org.apache.catalina.tribes.ChannelException
- Specified by:
stop
in interface org.apache.catalina.tribes.ChannelInterceptor
- Overrides:
stop
in class org.apache.catalina.tribes.group.ChannelInterceptorBase
- Throws:
org.apache.catalina.tribes.ChannelException
Copyright © 2011. All Rights Reserved.