org.jboss.jms.server.connectionfactory
Class ConnectionFactoryJNDIMapper

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

All Implemented Interfaces:

ConnectionFactoryManager, ClusterNotificationListener, MessagingComponent

public class ConnectionFactoryJNDIMapper
extends java.lang.Object
implements ConnectionFactoryManager, ClusterNotificationListener

Version:

$Revision: 3201 $ $Id: ConnectionFactoryJNDIMapper.java 3201 2007-10-19 10:39:50Z timfox $

Author:

Ovidiu Feodorov, Tim Fox, Clebert Suconic

Field Summary

protected javax.naming.Context	initialContext
protected ServerPeer	serverPeer

Constructor Summary

ConnectionFactoryJNDIMapper(ServerPeer serverPeer)

Method Summary

void	injectReplicator(Replicator replicator)
void	notify(ClusterNotification notification)
void	registerConnectionFactory(java.lang.String uniqueName, java.lang.String clientID, JNDIBindings jndiBindings, java.lang.String locatorURI, boolean clientPing, int prefetchSize, boolean slowConsumers, int defaultTempQueueFullSize, int defaultTempQueuePageSize, int defaultTempQueueDownCacheSize, int dupsOKBatchSize, boolean supportsFailover, boolean supportsLoadBalancing, LoadBalancingFactory loadBalancingFactory, boolean strictTck)
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

Constructor Detail

ConnectionFactoryJNDIMapper

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

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,
                                      boolean slowConsumers,
                                      int defaultTempQueueFullSize,
                                      int defaultTempQueuePageSize,
                                      int defaultTempQueueDownCacheSize,
                                      int dupsOKBatchSize,
                                      boolean supportsFailover,
                                      boolean supportsLoadBalancing,
                                      LoadBalancingFactory loadBalancingFactory,
                                      boolean strictTck)
                               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

notify

public void notify(ClusterNotification notification)

Specified by:

notify in interface ClusterNotificationListener

injectReplicator

public void injectReplicator(Replicator replicator)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object