org.jboss.messaging.core.client.impl
Class ConnectionManagerImpl

java.lang.Object
  extended by org.jboss.messaging.core.client.impl.ConnectionManagerImpl
All Implemented Interfaces:
ConnectionManager, ConnectionLifeCycleListener

public class ConnectionManagerImpl
extends java.lang.Object
implements ConnectionManager, ConnectionLifeCycleListener

A ConnectionManagerImpl

Author:
Tim Fox Created 27 Nov 2008 18:46:06

Constructor Summary
ConnectionManagerImpl(ClientSessionFactory factory, TransportConfiguration connectorConfig, TransportConfiguration backupConfig, boolean failoverOnServerShutdown, int maxConnections, long callTimeout, long clientFailureCheckPeriod, long connectionTTL, long retryInterval, double retryIntervalMultiplier, int reconnectAttempts, java.util.concurrent.ExecutorService threadPool, java.util.concurrent.ScheduledExecutorService scheduledThreadPool)
           
 
Method Summary
 void cancelPingerForConnectionID(java.lang.Object connectionID)
           
 void causeExit()
           
 void close()
           
 void connectionCreated(Connection connection)
           
 void connectionDestroyed(java.lang.Object connectionID)
           
 void connectionException(java.lang.Object connectionID, MessagingException me)
           
 ClientSession createSession(java.lang.String username, java.lang.String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize, int minLargeMessageSize, boolean blockOnAcknowledge, boolean autoGroup, int producerWindowSize, int consumerWindowSize, int producerMaxRate, int consumerMaxRate, boolean blockOnNonPersistentSend, boolean blockOnPersistentSend)
           
static void enableDebug()
           
static void failAllConnectionsForConnector(TransportConfiguration config)
           
protected  void finalize()
           
 RemotingConnection getConnection(int initialRefCount)
           
 int numConnections()
           
 int numSessions()
           
 void removeSession(ClientSessionInternal session)
           
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConnectionManagerImpl

public ConnectionManagerImpl(ClientSessionFactory factory,
                             TransportConfiguration connectorConfig,
                             TransportConfiguration backupConfig,
                             boolean failoverOnServerShutdown,
                             int maxConnections,
                             long callTimeout,
                             long clientFailureCheckPeriod,
                             long connectionTTL,
                             long retryInterval,
                             double retryIntervalMultiplier,
                             int reconnectAttempts,
                             java.util.concurrent.ExecutorService threadPool,
                             java.util.concurrent.ScheduledExecutorService scheduledThreadPool)
Method Detail

enableDebug

public static void enableDebug()

connectionCreated

public void connectionCreated(Connection connection)
Specified by:
connectionCreated in interface ConnectionLifeCycleListener

connectionDestroyed

public void connectionDestroyed(java.lang.Object connectionID)
Specified by:
connectionDestroyed in interface ConnectionLifeCycleListener

connectionException

public void connectionException(java.lang.Object connectionID,
                                MessagingException me)
Specified by:
connectionException in interface ConnectionLifeCycleListener

createSession

public ClientSession createSession(java.lang.String username,
                                   java.lang.String password,
                                   boolean xa,
                                   boolean autoCommitSends,
                                   boolean autoCommitAcks,
                                   boolean preAcknowledge,
                                   int ackBatchSize,
                                   int minLargeMessageSize,
                                   boolean blockOnAcknowledge,
                                   boolean autoGroup,
                                   int producerWindowSize,
                                   int consumerWindowSize,
                                   int producerMaxRate,
                                   int consumerMaxRate,
                                   boolean blockOnNonPersistentSend,
                                   boolean blockOnPersistentSend)
                            throws MessagingException
Specified by:
createSession in interface ConnectionManager
Throws:
MessagingException

removeSession

public void removeSession(ClientSessionInternal session)
Specified by:
removeSession in interface ConnectionManager

numConnections

public int numConnections()
Specified by:
numConnections in interface ConnectionManager

numSessions

public int numSessions()
Specified by:
numSessions in interface ConnectionManager

causeExit

public void causeExit()
Specified by:
causeExit in interface ConnectionManager

close

public void close()
Specified by:
close in interface ConnectionManager

cancelPingerForConnectionID

public void cancelPingerForConnectionID(java.lang.Object connectionID)

finalize

protected void finalize()
                 throws java.lang.Throwable
Overrides:
finalize in class java.lang.Object
Throws:
java.lang.Throwable

getConnection

public RemotingConnection getConnection(int initialRefCount)
Specified by:
getConnection in interface ConnectionManager

failAllConnectionsForConnector

public static void failAllConnectionsForConnector(TransportConfiguration config)


Copyright © 2006 JBoss Inc. All Rights Reserved.