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, Dispatcher, EnvelopeListener

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


Field Summary
protected  TribesCluster cluster
           
protected  java.util.Collection<org.apache.catalina.tribes.membership.StaticMember> staticMembers
           
 
Fields inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher
_executor, _factory, interceptors, log, rvMap
 
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<org.apache.catalina.tribes.membership.StaticMember> staticMembers)
           
TribesDispatcher(java.lang.String clusterName, java.lang.String localPeerName, EndPoint endPoint, java.util.Collection<org.apache.catalina.tribes.membership.StaticMember> staticMembers, boolean disableMulticasting, java.util.Properties mcastServiceProperties, int receiverPort)
           
 
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<org.apache.catalina.tribes.membership.StaticMember> getStaticMembers()
           
protected  void initStaticMembers(byte[] domain)
           
 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, getInterceptors, 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<org.apache.catalina.tribes.membership.StaticMember> 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<org.apache.catalina.tribes.membership.StaticMember> staticMembers)

TribesDispatcher

public TribesDispatcher(java.lang.String clusterName,
                        java.lang.String localPeerName,
                        EndPoint endPoint,
                        java.util.Collection<org.apache.catalina.tribes.membership.StaticMember> staticMembers,
                        boolean disableMulticasting,
                        java.util.Properties mcastServiceProperties,
                        int receiverPort)
Method Detail

initStaticMembers

protected void initStaticMembers(byte[] domain)

getStaticMembers

public java.util.Collection<org.apache.catalina.tribes.membership.StaticMember> 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


Copyright © 2010. All Rights Reserved.