org.codehaus.wadi.jgroups
Class JGroupsDispatcher
java.lang.Object
org.codehaus.wadi.group.impl.AbstractDispatcher
org.codehaus.wadi.jgroups.JGroupsDispatcher
- All Implemented Interfaces:
- Dispatcher, EnvelopeListener
public class JGroupsDispatcher
- extends AbstractDispatcher
A WADI Dispatcher mapped onto a number of JGroups listeners
- Version:
- $Revision: 2422 $
- Author:
- Jules Gosnell
Constructor Summary |
JGroupsDispatcher(java.lang.String clusterName,
java.lang.String localPeerName,
EndPoint endPoint,
java.lang.String config)
|
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, wait, wait, wait |
_excludeSelf
protected final boolean _excludeSelf
- See Also:
- Constant Field Values
_cluster
protected final JGroupsCluster _cluster
_localJGAddress
protected final org.jgroups.Address _localJGAddress
_dispatcher
protected final org.jgroups.blocks.MessageDispatcher _dispatcher
JGroupsDispatcher
public JGroupsDispatcher(java.lang.String clusterName,
java.lang.String localPeerName,
EndPoint endPoint,
java.lang.String config)
throws org.jgroups.ChannelException
- Throws:
org.jgroups.ChannelException
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
start
public void start()
throws MessageExchangeException
- Throws:
MessageExchangeException
stop
public void stop()
throws MessageExchangeException
- Throws:
MessageExchangeException
createEnvelope
public Envelope createEnvelope()
doSend
protected void doSend(Address target,
Envelope envelope)
throws MessageExchangeException
- Specified by:
doSend
in class AbstractDispatcher
- Throws:
MessageExchangeException
getPeerName
public java.lang.String getPeerName(Address address)
getCluster
public Cluster getCluster()
findRelevantSessionNames
public void findRelevantSessionNames(int numPartitions,
java.util.Collection[] resultSet)
Copyright © 2011. All Rights Reserved.