org.jboss.messaging.core.impl.clusterconnection
Class ClusterConnectionManager
java.lang.Object
org.jboss.messaging.core.impl.clusterconnection.ClusterConnectionManager
- All Implemented Interfaces:
- ClusterNotificationListener
public class ClusterConnectionManager
- extends java.lang.Object
- implements ClusterNotificationListener
This class handles connections to other nodes that are used to pull messages from remote queues to local queues
- Version:
- $Revision: $20 Jun 2007
$Id: $
- Author:
- Tim Fox
Constructor Summary |
ClusterConnectionManager(int nodeID,
java.lang.String connectionFactoryUniqueName,
boolean preserveOrdering,
java.lang.String suckerUser,
java.lang.String suckerPassword,
int maxRetry,
int retryInterval)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ClusterConnectionManager
public ClusterConnectionManager(int nodeID,
java.lang.String connectionFactoryUniqueName,
boolean preserveOrdering,
java.lang.String suckerUser,
java.lang.String suckerPassword,
int maxRetry,
int retryInterval)
injectReplicator
public void injectReplicator(Replicator replicator)
injectPostOffice
public void injectPostOffice(PostOffice postOffice)
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
getAllConnections
public java.util.Map getAllConnections()
resetAllSuckers
public void resetAllSuckers()
closeAllSuckers
public void closeAllSuckers()
notify
public void notify(ClusterNotification notification)
- Specified by:
notify
in interface ClusterNotificationListener
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2006 JBoss Inc. All Rights Reserved.