org.codehaus.wadi.tribes
Class TribesDispatcher

java.lang.Object
  extended by org.codehaus.wadi.group.impl.AbstractDispatcher
      extended by 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


Copyright © 2010. All Rights Reserved.