org.codehaus.wadi.gridstate.activecluster
Class CustomCluster

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

public class CustomCluster
extends DefaultCluster
implements ExtendedCluster


Constructor Summary
CustomCluster(LocalNode localNode, Topic dataTopic, Topic destination, Connection connection, Session session, MessageProducer producer, Timer timer, long inactiveTime)
           
 
Method Summary
 Destination createQueue(String name)
           
 Connection getConnection()
           
 
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
 
Methods inherited from interface org.activecluster.Service
start, stop
 

Constructor Detail

CustomCluster

public CustomCluster(LocalNode localNode,
                     Topic dataTopic,
                     Topic destination,
                     Connection connection,
                     Session session,
                     MessageProducer producer,
                     Timer timer,
                     long inactiveTime)
              throws JMSException
Method Detail

createQueue

public Destination createQueue(String name)
                        throws JMSException
Throws:
JMSException

getConnection

public Connection getConnection()
Specified by:
getConnection in interface ExtendedCluster


Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.