org.figure8.join.core.messaging
Class ConfigurableActiveMQConnectionFactoryBean

java.lang.Object
  org.activemq.jndi.JNDIBaseStorable
      org.activemq.ActiveMQConnectionFactory
          org.figure8.join.core.messaging.ConfigurableActiveMQConnectionFactoryBean

All Implemented Interfaces:

javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.naming.Referenceable, org.activemq.jndi.JNDIStorableInterface, org.activemq.management.StatsCapable, org.activemq.service.Service

public class ConfigurableActiveMQConnectionFactoryBean
extends org.activemq.ActiveMQConnectionFactory

This is an extension of ActiveMQ ActiveMQConnectionFactory that can be further configured using extra properties provided by a ActiveMQConfigurator instance.

Version:

$Revision: 1.2 $

Author:

Laurent Broudoux

See Also:

ActiveMQConfigurator

Field Summary

Fields inherited from class org.activemq.ActiveMQConnectionFactory

brokerContainer, brokerName, brokerURL, cachingEnabled, clientID, copyMessageOnSend, disableTimeStampsByDefault, doMessageCompression, doMessageFragmentation, internalConnection, J2EEcompliant, messageCompressionLevel, messageCompressionLimit, messageCompressionStrategy, messageFragmentationLimit, optimizedMessageDispatch, password, prepareMessageBodyOnSend, quickClose, useAsyncSend, userName

Constructor Summary

ConfigurableActiveMQConnectionFactoryBean()
Creates a new instance of ConfigurableActiveMQConnectionFactoryBean

Method Summary

javax.jms.Connection	createConnection(java.lang.String userName, java.lang.String password) Create a connection using properties from ActiveMQConfigurator
void	setActiveMQConfigurator(ActiveMQConfigurator configurator)

Methods inherited from class org.activemq.ActiveMQConnectionFactory

buildFromProperties, createBrokerConnector, createBrokerContainerFactory, createConnection, createMulticastClientID, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, createTransportChannel, createURI, createURI, ensureMulticastChannelIsAvailable, ensureServerIsAvailable, getBoolean, getBoolean, getBrokerContainer, getBrokerContainerFactory, getBrokerContext, getBrokerName, getBrokerName, getBrokerURL, getBrokerXmlConfig, getClientID, getContainer, getEmbeddedBroker, getFactoryStats, getMessageCompressionLimit, getMessageCompressionStrategy, getMessageFragmentationLimit, getPassword, getPrefetchPolicy, getStats, getUserName, getWireFormat, isCachingEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDoMessageCompression, isDoMessageFragmentation, isInternalConnection, isJ2EEcompliant, isOptimizedMessageDispatch, isPrepareMessageBodyOnSend, isQuickClose, isTurboBoost, isUseAsyncSend, isUseEmbeddedBroker, populateProperties, registerBroker, setBrokerContainerFactory, setBrokerContext, setBrokerName, setBrokerURL, setBrokerXmlConfig, setCachingEnabled, setClientID, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDoMessageCompression, setDoMessageFragmentation, setInternalConnection, setJ2EEcompliant, setMessageCompressionLimit, setMessageCompressionStrategy, setMessageFragmentationLimit, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setPrepareMessageBodyOnSend, setQuickClose, setTurboBoost, setUseAsyncSend, setUseEmbeddedBroker, setUserName, setWireFormat, setWireFormat, start, stop, unregisterBroker

Methods inherited from class org.activemq.jndi.JNDIBaseStorable

getProperties, getReference, setProperties

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigurableActiveMQConnectionFactoryBean

public ConfigurableActiveMQConnectionFactoryBean()

Creates a new instance of ConfigurableActiveMQConnectionFactoryBean

Method Detail

setActiveMQConfigurator

public void setActiveMQConfigurator(ActiveMQConfigurator configurator)

Parameters:

configurator - Helper for configuring connection factory

createConnection

public javax.jms.Connection createConnection(java.lang.String userName,
                                             java.lang.String password)
                                      throws javax.jms.JMSException

Create a connection using properties from ActiveMQConfigurator

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Overrides:

createConnection in class org.activemq.ActiveMQConnectionFactory

Parameters:

userName - Name of user for establishing connection

password - Password of user for establishing connection

Returns:

A new created connection

Throws:

javax.jms.JMSException - if connection cannot be established