org.codehaus.wadi.tribes
Class TribesDispatcher

java.lang.Object
  org.codehaus.wadi.group.impl.AbstractDispatcher
      org.codehaus.wadi.tribes.TribesDispatcher

All Implemented Interfaces:

org.apache.catalina.tribes.ChannelListener, Dispatcher, EnvelopeListener

public class TribesDispatcher
extends AbstractDispatcher
implements org.apache.catalina.tribes.ChannelListener

Field Summary

protected TribesCluster	cluster
protected java.util.Collection	staticMembers

Fields inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher

_executor, _factory, _log, _rvMap, interceptors

Constructor Summary

TribesDispatcher(java.lang.String clusterName, java.lang.String localPeerName, EndPoint endPoint)

TribesDispatcher(java.lang.String clusterName, java.lang.String localPeerName, EndPoint endPoint, java.util.Collection staticMembers)

Method Summary

boolean	accept(java.io.Serializable serializable, org.apache.catalina.tribes.Member member)
Envelope	createEnvelope()
protected void	doSend(Address target, Envelope envelope)
Cluster	getCluster()
java.lang.String	getPeerName(Address address)
java.util.Collection	getStaticMembers()
void	messageReceived(java.io.Serializable serializable, org.apache.catalina.tribes.Member member)
void	start() start
void	stop() stop

Methods inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher

addInterceptor, addRendezVousEnvelope, attemptMultiRendezVous, attemptRendezVous, doOnEnvelope, exchangeSend, exchangeSend, exchangeSend, exchangeSend, getContext, getExecutor, hook, newRendezVous, onEnvelope, onInboundEnvelope, onOutboundEnvelope, register, removeInterceptor, reply, reply, reply, send, send, send, send, setRendezVous, unregister

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.catalina.tribes.ChannelListener

equals, hashCode

Field Detail

cluster

protected TribesCluster cluster

staticMembers

protected final java.util.Collection staticMembers

Constructor Detail

TribesDispatcher

public TribesDispatcher(java.lang.String clusterName,
                        java.lang.String localPeerName,
                        EndPoint endPoint)

TribesDispatcher

public TribesDispatcher(java.lang.String clusterName,
                        java.lang.String localPeerName,
                        EndPoint endPoint,
                        java.util.Collection staticMembers)

Method Detail

getStaticMembers

public java.util.Collection getStaticMembers()

createEnvelope

public Envelope createEnvelope()

Specified by:

createEnvelope in interface Dispatcher

getCluster

public Cluster getCluster()

Specified by:

getCluster in interface Dispatcher

getPeerName

public java.lang.String getPeerName(Address address)

Specified by:

getPeerName in interface Dispatcher

doSend

protected void doSend(Address target,
                      Envelope envelope)
               throws MessageExchangeException

Specified by:

doSend in class AbstractDispatcher

Throws:

MessageExchangeException

messageReceived

public void messageReceived(java.io.Serializable serializable,
                            org.apache.catalina.tribes.Member member)

Specified by:

messageReceived in interface org.apache.catalina.tribes.ChannelListener

accept

public boolean accept(java.io.Serializable serializable,
                      org.apache.catalina.tribes.Member member)

Specified by:

accept in interface org.apache.catalina.tribes.ChannelListener

start

public void start()
           throws MessageExchangeException

start

Specified by:

start in interface Dispatcher

Throws:

MessageExchangeException

stop

public void stop()
          throws MessageExchangeException

stop

Specified by:

stop in interface Dispatcher

Throws:

MessageExchangeException