org.jboss.messaging.core.server.cluster.impl
Class ClusterConnectionImpl
java.lang.Object
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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.