org.jboss.jms.server
Interface ConnectionManager

All Superinterfaces:

MessagingComponent

All Known Implementing Classes:

SimpleConnectionManager

public interface ConnectionManager
extends MessagingComponent

An interface that allows management of ConnectionEnpoints and their association with remoting clients.

Version:

$Revision: 3057 $ $Id: ConnectionManager.java 3057 2007-08-27 18:07:52Z clebert.suconic@jboss.com $

Author:

Ovidiu Feodorov, Tim Fox

Method Summary

void	addConnectionFactoryCallback(java.lang.String uniqueName, java.lang.String JVMID, java.lang.String remotingSessionID, ServerInvokerCallbackHandler handler)
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.
ServerInvokerCallbackHandler[]	getConnectionFactoryCallback(java.lang.String uniqueName)
void	handleClientFailure(java.lang.String remotingSessionID, boolean clientToServer)
void	registerConnection(java.lang.String jmsClientVMId, java.lang.String remotingClientSessionID, ConnectionEndpoint endpoint)
void	removeConnectionFactoryCallback(java.lang.String uniqueName, java.lang.String JVMID, ServerInvokerCallbackHandler handler)
ConnectionEndpoint	unregisterConnection(java.lang.String jmsClientVMID, java.lang.String remotingClientSessionID)

Methods inherited from interface org.jboss.messaging.core.contract.MessagingComponent

start, stop

Method Detail

registerConnection

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

unregisterConnection

ConnectionEndpoint unregisterConnection(java.lang.String jmsClientVMID,
                                        java.lang.String remotingClientSessionID)

Returns:

null if there is no such connection.

containsRemotingSession

boolean containsRemotingSession(java.lang.String remotingClientSessionID)

getActiveConnections

java.util.List getActiveConnections()

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.

Returns:

List

addConnectionFactoryCallback

void addConnectionFactoryCallback(java.lang.String uniqueName,
                                  java.lang.String JVMID,
                                  java.lang.String remotingSessionID,
                                  ServerInvokerCallbackHandler handler)

removeConnectionFactoryCallback

void removeConnectionFactoryCallback(java.lang.String uniqueName,
                                     java.lang.String JVMID,
                                     ServerInvokerCallbackHandler handler)

getConnectionFactoryCallback

ServerInvokerCallbackHandler[] getConnectionFactoryCallback(java.lang.String uniqueName)

handleClientFailure

void handleClientFailure(java.lang.String remotingSessionID,
                         boolean clientToServer)

Parameters:

clientToServer - - true if the failure has been detected on a direct connection from client to this server, false if the failure has been detected while trying to send a callback from this server to the client.