org.codehaus.wadi.gridstate.activecluster
Class ActiveClusterDispatcher
java.lang.Object
org.codehaus.wadi.gridstate.impl.AbstractDispatcher
org.codehaus.wadi.gridstate.activecluster.ActiveClusterDispatcher
- All Implemented Interfaces:
- Dispatcher, MessageListener
- public class ActiveClusterDispatcher
- extends AbstractDispatcher
A Dispatcher for ActiveCluster
- Version:
- $Revision: 1430 $
- Author:
- Jules Gosnell
Methods inherited from class org.codehaus.wadi.gridstate.impl.AbstractDispatcher |
attemptRendezVous, deregister, exchangeReply, exchangeReplyLoop, exchangeSend, exchangeSend, exchangeSend, exchangeSendLoop, forward, forward, getExecutor, getInactiveTime, getNodeName, getRendezVousMap, newDeregister, newRegister, nextCorrelationId, onMessage, register, register, reply, reply, send, setRendezVous |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_incomingCorrelationIdKey
protected static String _incomingCorrelationIdKey
_outgoingCorrelationIdKey
protected static String _outgoingCorrelationIdKey
_cluster
protected Cluster _cluster
_clusterConsumer
protected MessageConsumer _clusterConsumer
_nodeConsumer
protected MessageConsumer _nodeConsumer
_clusterUri
protected final String _clusterUri
_connectionFactory
protected org.activemq.ActiveMQConnectionFactory _connectionFactory
_clusterFactory
public CustomClusterFactory _clusterFactory
ActiveClusterDispatcher
public ActiveClusterDispatcher(String nodeName,
String clusterName,
String clusterUri,
long inactiveTime)
getCluster
public Cluster getCluster()
addDestination
public MessageConsumer addDestination(Destination destination)
throws JMSException
- Throws:
JMSException
removeDestination
public void removeDestination(MessageConsumer consumer)
throws JMSException
- Throws:
JMSException
init
public void init(DispatcherConfig config)
throws Exception
- Specified by:
init
in interface Dispatcher
- Overrides:
init
in class AbstractDispatcher
- Throws:
Exception
start
public void start()
throws Exception
- Throws:
Exception
stop
public void stop()
throws Exception
- Throws:
Exception
getNumNodes
public int getNumNodes()
createObjectMessage
public ObjectMessage createObjectMessage()
throws Exception
- Throws:
Exception
send
public void send(Destination to,
ObjectMessage message)
throws Exception
- Throws:
Exception
getLocalDestination
public Destination getLocalDestination()
getClusterDestination
public Destination getClusterDestination()
getDistributedState
public Map getDistributedState()
setDistributedState
public void setDistributedState(Map state)
throws Exception
- Throws:
Exception
getNodeName
public String getNodeName(Destination destination)
getIncomingCorrelationId
public String getIncomingCorrelationId(ObjectMessage message)
throws Exception
- Throws:
Exception
setIncomingCorrelationId
public void setIncomingCorrelationId(ObjectMessage message,
String id)
throws JMSException
- Throws:
JMSException
getOutgoingCorrelationId
public String getOutgoingCorrelationId(ObjectMessage message)
throws JMSException
- Throws:
JMSException
setOutgoingCorrelationId
public void setOutgoingCorrelationId(ObjectMessage message,
String id)
throws JMSException
- Throws:
JMSException
findRelevantSessionNames
public void findRelevantSessionNames(int numPartitions,
Collection[] resultSet)
setClusterListener
public void setClusterListener(ClusterListener listener)
Copyright © 2004-2008 Core Developers Network Ltd.. All Rights Reserved.