org.codehaus.wadi.gridstate.activecluster
Class DummyCluster
java.lang.Object
org.codehaus.wadi.gridstate.activecluster.DummyCluster
- All Implemented Interfaces:
- Cluster, ExtendedCluster, Service
- public class DummyCluster
- extends Object
- implements ExtendedCluster
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_localNode
protected final LocalNode _localNode
DummyCluster
public DummyCluster()
createQueue
public Destination createQueue(String name)
getDestination
public Topic getDestination()
- Specified by:
getDestination
in interface Cluster
getNodes
public Map getNodes()
- Specified by:
getNodes
in interface Cluster
addClusterListener
public void addClusterListener(ClusterListener listener)
- Specified by:
addClusterListener
in interface Cluster
removeClusterListener
public void removeClusterListener(ClusterListener listener)
- Specified by:
removeClusterListener
in interface Cluster
getLocalNode
public LocalNode getLocalNode()
- Specified by:
getLocalNode
in interface Cluster
send
public void send(Destination destination,
Message message)
- Specified by:
send
in interface Cluster
createConsumer
public MessageConsumer createConsumer(Destination destination)
- Specified by:
createConsumer
in interface Cluster
createConsumer
public MessageConsumer createConsumer(Destination destination,
String selector)
- Specified by:
createConsumer
in interface Cluster
createConsumer
public MessageConsumer createConsumer(Destination destination,
String selector,
boolean noLocal)
- Specified by:
createConsumer
in interface Cluster
createMessage
public Message createMessage()
- Specified by:
createMessage
in interface Cluster
createBytesMessage
public BytesMessage createBytesMessage()
- Specified by:
createBytesMessage
in interface Cluster
createMapMessage
public MapMessage createMapMessage()
- Specified by:
createMapMessage
in interface Cluster
createObjectMessage
public ObjectMessage createObjectMessage()
- Specified by:
createObjectMessage
in interface Cluster
createObjectMessage
public ObjectMessage createObjectMessage(Serializable object)
- Specified by:
createObjectMessage
in interface Cluster
createStreamMessage
public StreamMessage createStreamMessage()
- Specified by:
createStreamMessage
in interface Cluster
createTextMessage
public TextMessage createTextMessage()
- Specified by:
createTextMessage
in interface Cluster
createTextMessage
public TextMessage createTextMessage(String text)
- Specified by:
createTextMessage
in interface Cluster
waitForClusterToComplete
public boolean waitForClusterToComplete(int expectedCount,
long timeout)
- Specified by:
waitForClusterToComplete
in interface Cluster
start
public void start()
- Specified by:
start
in interface Service
stop
public void stop()
- Specified by:
stop
in interface Service
getConnection
public Connection getConnection()
- Specified by:
getConnection
in interface ExtendedCluster
setElectionStrategy
public void setElectionStrategy(ElectionStrategy strategy)
Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.