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
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)
|
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 |
cluster
protected TribesCluster cluster
staticMembers
protected final java.util.Collection staticMembers
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)
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
Copyright © 2011. All Rights Reserved.