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