org.codehaus.wadi.jgroups
Class JGroupsDispatcher
java.lang.Object
org.codehaus.wadi.group.impl.AbstractDispatcher
org.codehaus.wadi.jgroups.JGroupsDispatcher
- All Implemented Interfaces:
- org.codehaus.wadi.group.Dispatcher, org.codehaus.wadi.group.EnvelopeListener
public class JGroupsDispatcher
- extends org.codehaus.wadi.group.impl.AbstractDispatcher
A WADI Dispatcher mapped onto a number of JGroups listeners
- Version:
- $Revision: 2308 $
- Author:
- Jules Gosnell
Fields inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher |
_executor, _factory, _log, _rvMap, interceptors |
Constructor Summary |
JGroupsDispatcher(java.lang.String clusterName,
java.lang.String localPeerName,
org.codehaus.wadi.group.EndPoint endPoint,
java.lang.String config)
|
Method Summary |
org.codehaus.wadi.group.Envelope |
createEnvelope()
|
protected void |
doSend(org.codehaus.wadi.group.Address target,
org.codehaus.wadi.group.Envelope envelope)
|
void |
findRelevantSessionNames(int numPartitions,
java.util.Collection[] resultSet)
|
org.codehaus.wadi.group.Cluster |
getCluster()
|
java.lang.String |
getPeerName(org.codehaus.wadi.group.Address address)
|
protected void |
hook()
|
void |
start()
|
void |
stop()
|
java.lang.String |
toString()
|
Methods inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher |
addInterceptor, addRendezVousEnvelope, attemptMultiRendezVous, attemptRendezVous, doOnEnvelope, exchangeSend, exchangeSend, exchangeSend, exchangeSend, getContext, getExecutor, 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,
org.codehaus.wadi.group.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 org.codehaus.wadi.group.MessageExchangeException
- Throws:
org.codehaus.wadi.group.MessageExchangeException
stop
public void stop()
throws org.codehaus.wadi.group.MessageExchangeException
- Throws:
org.codehaus.wadi.group.MessageExchangeException
createEnvelope
public org.codehaus.wadi.group.Envelope createEnvelope()
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
getPeerName
public java.lang.String getPeerName(org.codehaus.wadi.group.Address address)
getCluster
public org.codehaus.wadi.group.Cluster getCluster()
hook
protected void hook()
- Overrides:
hook
in class org.codehaus.wadi.group.impl.AbstractDispatcher
findRelevantSessionNames
public void findRelevantSessionNames(int numPartitions,
java.util.Collection[] resultSet)
Copyright © 2008. All Rights Reserved.