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<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)
|
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 |
cluster
protected TribesCluster cluster
staticMembers
protected final java.util.Collection<org.apache.catalina.tribes.membership.StaticMember> 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<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)
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 © 2011. All Rights Reserved.