org.codehaus.wadi.jgroups
Class JGroupsDispatcher

java.lang.Object
  extended by org.codehaus.wadi.group.impl.AbstractDispatcher
      extended by 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

Field Summary
protected  JGroupsCluster _cluster
           
protected  org.jgroups.blocks.MessageDispatcher _dispatcher
           
protected  boolean _excludeSelf
           
protected  org.jgroups.Address _localJGAddress
           
 
Fields inherited from class org.codehaus.wadi.group.impl.AbstractDispatcher
_executor, _factory, interceptors, log, rvMap
 
Constructor Summary
JGroupsDispatcher(java.lang.String clusterName, java.lang.String localPeerName, EndPoint endPoint, java.lang.String config)
           
 
Method Summary
 Envelope createEnvelope()
           
protected  void doSend(Address target, Envelope envelope)
           
 void findRelevantSessionNames(int numPartitions, java.util.Collection[] resultSet)
           
 Cluster getCluster()
           
 java.lang.String getPeerName(Address address)
           
 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, 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
 

Field Detail

_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
Constructor Detail

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
Method Detail

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 © 2010. All Rights Reserved.