org.jboss.jms.server.connectionfactory
Class ConnectionFactoryJNDIMapper

java.lang.Object
  org.jboss.jms.server.connectionfactory.ConnectionFactoryJNDIMapper

All Implemented Interfaces:

ConnectionFactoryManager, MessagingComponent, ReplicationListener

public class ConnectionFactoryJNDIMapper

extends java.lang.Object

implements ConnectionFactoryManager, ReplicationListener

Version:

$Revision: 2723 $ $Id: ConnectionFactoryJNDIMapper.java 2723 2007-05-24 13:15:35Z timfox $

Author:

Ovidiu Feodorov, Tim Fox, Clebert Suconic

Field Summary

protected java.util.Map	delegates
protected java.util.Map	endpoints
protected java.util.Map	failoverMap
protected javax.naming.Context	initialContext
protected ServerPeer	serverPeer

Constructor Summary

ConnectionFactoryJNDIMapper(ServerPeer serverPeer)

Method Summary

void	injectReplicator(Replicator replicator)
void	onReplicationChange(java.io.Serializable key, java.util.Map updatedReplicantMap, boolean added, int originatorNodeID)
void	registerConnectionFactory(java.lang.String uniqueName, java.lang.String clientID, JNDIBindings jndiBindings, java.lang.String locatorURI, boolean clientPing, int prefetchSize, int defaultTempQueueFullSize, int defaultTempQueuePageSize, int defaultTempQueueDownCacheSize, int dupsOKBatchSize, boolean supportsFailover, boolean supportsLoadBalancing, LoadBalancingFactory loadBalancingFactory)
void	start()
void	stop()
java.lang.String	toString()
void	unregisterConnectionFactory(java.lang.String uniqueName, boolean supportsFailover, boolean supportsLoadBalancing)

Methods inherited from class java.lang.Object

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

Field Detail

initialContext

protected javax.naming.Context initialContext

serverPeer

protected ServerPeer serverPeer

endpoints

protected java.util.Map endpoints

delegates

protected java.util.Map delegates

failoverMap

protected java.util.Map failoverMap

Constructor Detail

ConnectionFactoryJNDIMapper

public ConnectionFactoryJNDIMapper(ServerPeer serverPeer)
                            throws java.lang.Exception

Method Detail

registerConnectionFactory

public void registerConnectionFactory(java.lang.String uniqueName,
                                      java.lang.String clientID,
                                      JNDIBindings jndiBindings,
                                      java.lang.String locatorURI,
                                      boolean clientPing,
                                      int prefetchSize,
                                      int defaultTempQueueFullSize,
                                      int defaultTempQueuePageSize,
                                      int defaultTempQueueDownCacheSize,
                                      int dupsOKBatchSize,
                                      boolean supportsFailover,
                                      boolean supportsLoadBalancing,
                                      LoadBalancingFactory loadBalancingFactory)
                               throws java.lang.Exception

Specified by:

registerConnectionFactory in interface ConnectionFactoryManager

Parameters:

loadBalancingFactory - - ignored for non-clustered connection factories.

jndiBindings - - if null, the connection factory will be created and registered with the AOP subsystem, but not bound in JNDI.

Throws:

java.lang.Exception

unregisterConnectionFactory

public void unregisterConnectionFactory(java.lang.String uniqueName,
                                        boolean supportsFailover,
                                        boolean supportsLoadBalancing)
                                 throws java.lang.Exception

Specified by:

unregisterConnectionFactory in interface ConnectionFactoryManager

Throws:

java.lang.Exception

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

onReplicationChange

public void onReplicationChange(java.io.Serializable key,
                                java.util.Map updatedReplicantMap,
                                boolean added,
                                int originatorNodeID)

Specified by:

onReplicationChange in interface ReplicationListener

Parameters:

updatedReplicantMap - Map>

injectReplicator

public void injectReplicator(Replicator replicator)

toString

public java.lang.String toString()