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(boolean xa, int nodeID, java.lang.String connectionFactoryUniqueName, boolean preserveOrdering, java.lang.String suckerUser, java.lang.String suckerPassword)

Method Summary

void	closeAllSuckers()
java.util.Map	getAllConnections()
void	injectPostOffice(PostOffice postOffice)
void	injectReplicator(Replicator replicator)
void	notify(ClusterNotification notification)
void	resetAllSuckers()
void	setIsXA(boolean xa)
void	start()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClusterConnectionManager

public ClusterConnectionManager(boolean xa,
                                int nodeID,
                                java.lang.String connectionFactoryUniqueName,
                                boolean preserveOrdering,
                                java.lang.String suckerUser,
                                java.lang.String suckerPassword)

Method Detail

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()

setIsXA

public void setIsXA(boolean xa)
             throws java.lang.Exception

Throws:

java.lang.Exception

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