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, org.codehaus.wadi.group.Dispatcher, org.codehaus.wadi.group.EnvelopeListener

public class TribesDispatcher
extends org.codehaus.wadi.group.impl.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, org.codehaus.wadi.group.EndPoint endPoint)

TribesDispatcher(java.lang.String clusterName, java.lang.String localPeerName, org.codehaus.wadi.group.EndPoint endPoint, java.util.Collection staticMembers)

Method Summary

boolean	accept(java.io.Serializable serializable, org.apache.catalina.tribes.Member member)
org.codehaus.wadi.group.Envelope	createEnvelope()
protected void	doSend(org.codehaus.wadi.group.Address target, org.codehaus.wadi.group.Envelope envelope)
org.codehaus.wadi.group.Cluster	getCluster()
java.lang.String	getPeerName(org.codehaus.wadi.group.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,
                        org.codehaus.wadi.group.EndPoint endPoint)

TribesDispatcher

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

Method Detail

getStaticMembers

public java.util.Collection getStaticMembers()

createEnvelope

public org.codehaus.wadi.group.Envelope createEnvelope()

Specified by:

createEnvelope in interface org.codehaus.wadi.group.Dispatcher

getCluster

public org.codehaus.wadi.group.Cluster getCluster()

Specified by:

getCluster in interface org.codehaus.wadi.group.Dispatcher

getPeerName

public java.lang.String getPeerName(org.codehaus.wadi.group.Address address)

Specified by:

getPeerName in interface org.codehaus.wadi.group.Dispatcher

doSend

protected void doSend(org.codehaus.wadi.group.Address target,
                      org.codehaus.wadi.group.Envelope envelope)
               throws org.codehaus.wadi.group.MessageExchangeException

Specified by:

doSend in class org.codehaus.wadi.group.impl.AbstractDispatcher

Throws:

org.codehaus.wadi.group.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 org.codehaus.wadi.group.MessageExchangeException

start

Specified by:

start in interface org.codehaus.wadi.group.Dispatcher

Throws:

org.codehaus.wadi.group.MessageExchangeException

stop

public void stop()
          throws org.codehaus.wadi.group.MessageExchangeException

stop

Specified by:

stop in interface org.codehaus.wadi.group.Dispatcher

Throws:

org.codehaus.wadi.group.MessageExchangeException