org.jboss.messaging.core.server.cluster.impl
Class ClusterConnectionImpl

java.lang.Object
  extended by org.jboss.messaging.core.server.cluster.impl.ClusterConnectionImpl
All Implemented Interfaces:
DiscoveryListener, ClusterConnection, MessagingComponent

public class ClusterConnectionImpl
extends java.lang.Object
implements ClusterConnection, DiscoveryListener

A ClusterConnectionImpl

Author:
Tim Fox Created 21 Jan 2009 14:43:05

Constructor Summary
ClusterConnectionImpl(SimpleString name, SimpleString address, long retryInterval, boolean useDuplicateDetection, boolean routeWhenNoConsumers, ExecutorFactory executorFactory, MessagingServer server, PostOffice postOffice, ManagementService managementService, java.util.concurrent.ScheduledExecutorService scheduledExecutor, DiscoveryGroup discoveryGroup, int maxHops, UUID nodeUUID, Channel replicatingChannel, boolean backup)
           
ClusterConnectionImpl(SimpleString name, SimpleString address, long retryInterval, boolean useDuplicateDetection, boolean routeWhenNoConsumers, ExecutorFactory executorFactory, MessagingServer server, PostOffice postOffice, ManagementService managementService, java.util.concurrent.ScheduledExecutorService scheduledExecutor, java.util.List<Pair<TransportConfiguration,TransportConfiguration>> connectors, int maxHops, UUID nodeUUID, Channel replicatingChannel, boolean backup)
           
 
Method Summary
 void activate()
           
 void connectorsChanged()
           
 SimpleString getName()
           
 void handleReplicatedAddBinding(SimpleString address, SimpleString uniqueName, SimpleString routingName, int queueID, SimpleString filterString, SimpleString queueName, int distance)
           
 boolean isStarted()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClusterConnectionImpl

public ClusterConnectionImpl(SimpleString name,
                             SimpleString address,
                             long retryInterval,
                             boolean useDuplicateDetection,
                             boolean routeWhenNoConsumers,
                             ExecutorFactory executorFactory,
                             MessagingServer server,
                             PostOffice postOffice,
                             ManagementService managementService,
                             java.util.concurrent.ScheduledExecutorService scheduledExecutor,
                             java.util.List<Pair<TransportConfiguration,TransportConfiguration>> connectors,
                             int maxHops,
                             UUID nodeUUID,
                             Channel replicatingChannel,
                             boolean backup)
                      throws java.lang.Exception
Throws:
java.lang.Exception

ClusterConnectionImpl

public ClusterConnectionImpl(SimpleString name,
                             SimpleString address,
                             long retryInterval,
                             boolean useDuplicateDetection,
                             boolean routeWhenNoConsumers,
                             ExecutorFactory executorFactory,
                             MessagingServer server,
                             PostOffice postOffice,
                             ManagementService managementService,
                             java.util.concurrent.ScheduledExecutorService scheduledExecutor,
                             DiscoveryGroup discoveryGroup,
                             int maxHops,
                             UUID nodeUUID,
                             Channel replicatingChannel,
                             boolean backup)
                      throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface MessagingComponent
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface MessagingComponent
Throws:
java.lang.Exception

isStarted

public boolean isStarted()
Specified by:
isStarted in interface MessagingComponent

getName

public SimpleString getName()
Specified by:
getName in interface ClusterConnection

activate

public void activate()
Specified by:
activate in interface ClusterConnection

connectorsChanged

public void connectorsChanged()
Specified by:
connectorsChanged in interface DiscoveryListener

handleReplicatedAddBinding

public void handleReplicatedAddBinding(SimpleString address,
                                       SimpleString uniqueName,
                                       SimpleString routingName,
                                       int queueID,
                                       SimpleString filterString,
                                       SimpleString queueName,
                                       int distance)
                                throws java.lang.Exception
Specified by:
handleReplicatedAddBinding in interface ClusterConnection
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.