org.jboss.jms.server.connectionmanager
Class SimpleConnectionManager

java.lang.Object
  org.jboss.jms.server.connectionmanager.SimpleConnectionManager

All Implemented Interfaces:

ConnectionManager, ClusterNotificationListener, MessagingComponent

public class SimpleConnectionManager
extends java.lang.Object
implements ConnectionManager, ClusterNotificationListener

Version:

$Revision: 4986 $ $Id: SimpleConnectionManager.java 4986 2008-09-18 22:11:43Z clebert.suconic@jboss.com $

Author:

Tim Fox, Ovidiu Feodorov

Constructor Summary

SimpleConnectionManager()

Method Summary

boolean	containsRemotingSession(java.lang.String remotingClientSessionID)
java.util.List	getActiveConnections() Returns a list of active connection endpoints currently maintained by an instance of this manager.
java.util.Map	getClients()
void	handleClientFailure(java.lang.String remotingSessionID)
void	handleConnectionException(java.lang.Throwable t, Client client) Be aware that ConnectionNotifier uses to call this method with null Throwables.
void	injectReplicator(Replicator replicator)
void	notify(ClusterNotification notification) Closing connections that are coming from a failed node
void	registerConnection(java.lang.String jmsClientVMID, java.lang.String remotingClientSessionID, ConnectionEndpoint endpoint)
void	registerConnectionFactory(ServerConnectionFactoryEndpoint cf)
void	registerConnectionFactoryCallback(java.lang.String JVMID, java.lang.String remotingSessionID, InvokerCallbackHandler handler)
void	start()
void	stop()
java.lang.String	toString()
ConnectionEndpoint	unregisterConnection(java.lang.String jmsClientVMId, java.lang.String remotingClientSessionID)
void	unregisterConnectionFactory(ServerConnectionFactoryEndpoint cf)
void	unregisterConnectionFactoryCallback(java.lang.String JVMID, java.lang.String remotingSessionID)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleConnectionManager

public SimpleConnectionManager()

Method Detail

registerConnection

public void registerConnection(java.lang.String jmsClientVMID,
                               java.lang.String remotingClientSessionID,
                               ConnectionEndpoint endpoint)

Specified by:

registerConnection in interface ConnectionManager

registerConnectionFactoryCallback

public void registerConnectionFactoryCallback(java.lang.String JVMID,
                                              java.lang.String remotingSessionID,
                                              InvokerCallbackHandler handler)

Specified by:

registerConnectionFactoryCallback in interface ConnectionManager

unregisterConnection

public ConnectionEndpoint unregisterConnection(java.lang.String jmsClientVMId,
                                               java.lang.String remotingClientSessionID)

Specified by:

unregisterConnection in interface ConnectionManager

Returns:

null if there is no such connection.

unregisterConnectionFactoryCallback

public void unregisterConnectionFactoryCallback(java.lang.String JVMID,
                                                java.lang.String remotingSessionID)

Specified by:

unregisterConnectionFactoryCallback in interface ConnectionManager

getActiveConnections

public java.util.List getActiveConnections()

Description copied from interface: ConnectionManager

Returns a list of active connection endpoints currently maintained by an instance of this manager. The implementation should make a copy of the list to avoid ConcurrentModificationException. The list could be empty, but never null.

Specified by:

getActiveConnections in interface ConnectionManager

Returns:

List

handleClientFailure

public void handleClientFailure(java.lang.String remotingSessionID)

Specified by:

handleClientFailure in interface ConnectionManager

registerConnectionFactory

public void registerConnectionFactory(ServerConnectionFactoryEndpoint cf)

Specified by:

registerConnectionFactory in interface ConnectionManager

unregisterConnectionFactory

public void unregisterConnectionFactory(ServerConnectionFactoryEndpoint cf)

Specified by:

unregisterConnectionFactory in interface ConnectionManager

handleConnectionException

public void handleConnectionException(java.lang.Throwable t,
                                      Client client)

Be aware that ConnectionNotifier uses to call this method with null Throwables.

Parameters:

t - - plan for it to be null!

notify

public void notify(ClusterNotification notification)

Closing connections that are coming from a failed node

Specified by:

notify in interface ClusterNotificationListener

Parameters:

notification -

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

containsRemotingSession

public boolean containsRemotingSession(java.lang.String remotingClientSessionID)

Specified by:

containsRemotingSession in interface ConnectionManager

getClients

public java.util.Map getClients()

injectReplicator

public void injectReplicator(Replicator replicator)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object