org.codehaus.wadi.tribes
Class WadiMemberInterceptor

java.lang.Object
  extended by org.apache.catalina.tribes.group.ChannelInterceptorBase
      extended by 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 Class Summary
static class WadiMemberInterceptor.MemberComparator
           
 
Nested classes/interfaces inherited from interface org.apache.catalina.tribes.ChannelInterceptor
org.apache.catalina.tribes.ChannelInterceptor.InterceptorEvent
 
Field Summary
protected  WadiMemberInterceptor.MemberComparator comp
           
protected static int instanceCounters
           
protected static java.util.HashMap map
           
protected  java.lang.Object memberMutex
           
protected  boolean memberNotification
           
protected static java.util.HashMap reversemap
           
protected  int startLevel
           
 
Fields inherited from class org.apache.catalina.tribes.group.ChannelInterceptorBase
log, optionFlag
 
Constructor Summary
WadiMemberInterceptor()
           
 
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
 

Field Detail

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
Constructor Detail

WadiMemberInterceptor

public WadiMemberInterceptor()
Method Detail

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.