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

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)