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