org.codehaus.wadi.gridstate.activecluster
Class DummyCluster

java.lang.Object
  extended byorg.codehaus.wadi.gridstate.activecluster.DummyCluster
All Implemented Interfaces:
Cluster, ExtendedCluster, Service

public class DummyCluster
extends Object
implements ExtendedCluster


Field Summary
protected  LocalNode _localNode
           
 
Constructor Summary
DummyCluster()
           
 
Method Summary
 void addClusterListener(ClusterListener listener)
           
 BytesMessage createBytesMessage()
           
 MessageConsumer createConsumer(Destination destination)
           
 MessageConsumer createConsumer(Destination destination, String selector)
           
 MessageConsumer createConsumer(Destination destination, String selector, boolean noLocal)
           
 MapMessage createMapMessage()
           
 Message createMessage()
           
 ObjectMessage createObjectMessage()
           
 ObjectMessage createObjectMessage(Serializable object)
           
 Destination createQueue(String name)
           
 StreamMessage createStreamMessage()
           
 TextMessage createTextMessage()
           
 TextMessage createTextMessage(String text)
           
 Connection getConnection()
           
 Topic getDestination()
           
 LocalNode getLocalNode()
           
 Map getNodes()
           
 void removeClusterListener(ClusterListener listener)
           
 void send(Destination destination, Message message)
           
 void setElectionStrategy(ElectionStrategy strategy)
           
 void start()
           
 void stop()
           
 boolean waitForClusterToComplete(int expectedCount, long timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_localNode

protected final LocalNode _localNode
Constructor Detail

DummyCluster

public DummyCluster()
Method Detail

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.