org.codehaus.wadi.gridstate.activecluster
Class CustomCluster
java.lang.Object
org.activecluster.impl.DefaultCluster
org.codehaus.wadi.gridstate.activecluster.CustomCluster
- All Implemented Interfaces:
- Cluster, ExtendedCluster, Service
- public class CustomCluster
- extends DefaultCluster
- implements ExtendedCluster
Methods inherited from class org.activecluster.impl.DefaultCluster |
addClusterListener, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getDestination, getLocalNode, getNodes, getSession, removeClusterListener, send, start, stop, waitForClusterToComplete |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.activecluster.Cluster |
addClusterListener, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getDestination, getLocalNode, getNodes, removeClusterListener, send, waitForClusterToComplete |
CustomCluster
public CustomCluster(LocalNode localNode,
Topic dataTopic,
Topic destination,
Connection connection,
Session session,
MessageProducer producer,
Timer timer,
long inactiveTime)
throws JMSException
createQueue
public Destination createQueue(String name)
throws JMSException
- Throws:
JMSException
getConnection
public Connection getConnection()
- Specified by:
getConnection
in interface ExtendedCluster
Copyright © 2004-2008 Core Developers Network Ltd.. All Rights Reserved.