org.apache.activemq.camel.component
Class ActiveMQConfiguration

java.lang.Object
  extended by org.apache.camel.component.jms.JmsConfiguration
      extended by org.apache.activemq.camel.component.ActiveMQConfiguration
All Implemented Interfaces:
Cloneable

public class ActiveMQConfiguration
extends org.apache.camel.component.jms.JmsConfiguration


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.camel.component.jms.JmsConfiguration
org.apache.camel.component.jms.JmsConfiguration.CamelJmsTemplate
 
Field Summary
 
Fields inherited from class org.apache.camel.component.jms.JmsConfiguration
QUEUE_PREFIX, TEMP_QUEUE_PREFIX, TEMP_TOPIC_PREFIX, TOPIC_PREFIX
 
Constructor Summary
ActiveMQConfiguration()
           
 
Method Summary
protected  ConnectionFactory createConnectionFactory()
           
protected  ConnectionFactory createPooledConnectionFactory(ActiveMQConnectionFactory connectionFactory)
           
protected  org.springframework.transaction.PlatformTransactionManager createTransactionManager()
          Factory method to create a default transaction manager if one is not specified
 String getBrokerURL()
           
 String getPassword()
           
 String getUserName()
           
 boolean isUsePooledConnection()
           
 boolean isUseSingleConnection()
           
static Class<?> loadClass(String name, ClassLoader loader)
           
protected  void setActiveMQComponent(ActiveMQComponent activeMQComponent)
           
 void setBrokerURL(String brokerURL)
          Sets the broker URL to use to connect to ActiveMQ using the ActiveMQ URI format
 void setPassword(String password)
          Sets the password/passcode used to login to ActiveMQ
 void setUsePooledConnection(boolean usePooledConnection)
          Enables or disables whether a PooledConnectionFactory will be used so that when messages are sent to ActiveMQ from outside of a message consuming thread, pooling will be used rather than the default with the Spring JmsTemplate which will create a new connection, session, producer for each message then close them all down again.
 void setUserName(String userName)
          Sets the username to be used to login to ActiveMQ
 void setUseSingleConnection(boolean useSingleConnection)
          Enables or disables whether a Spring SingleConnectionFactory will be used so that when messages are sent to ActiveMQ from outside of a message consuming thread, pooling will be used rather than the default with the Spring JmsTemplate which will create a new connection, session, producer for each message then close them all down again.
 
Methods inherited from class org.apache.camel.component.jms.JmsConfiguration
chooseMessageListenerContainerImplementation, configuredQoS, configureMessageListener, configureMessageListenerContainer, copy, createDestinationResolver, createInOnlyTemplate, createInOutTemplate, createListenerConnectionFactory, createMessageListenerContainer, createTemplateConnectionFactory, defaultCacheLevel, getAcknowledgementMode, getAcknowledgementModeName, getCacheLevel, getCacheLevelName, getClientId, getConcurrentConsumers, getConnectionFactory, getConsumerType, getDefaultTaskExecutorType, getDestinationResolver, getDurableSubscriptionName, getErrorHandler, getErrorHandlerLoggingLevel, getExceptionListener, getIdleConsumerLimit, getIdleTaskExecutionLimit, getJmsKeyFormatStrategy, getJmsMessageType, getJmsOperations, getListenerConnectionFactory, getMaxConcurrentConsumers, getMaxMessagesPerTask, getMessageConverter, getMessageListenerContainerFactory, getMetadataJmsOperations, getPriority, getProviderMetadata, getReceiveTimeout, getRecoveryInterval, getReplyTo, getReplyToCacheLevelName, getReplyToDestinationSelectorName, getReplyToType, getRequestTimeout, getRequestTimeoutCheckerInterval, getTaskExecutor, getTemplateConnectionFactory, getTimeToLive, getTransactionManager, getTransactionName, getTransactionTimeout, isAcceptMessagesWhileStopping, isAllowNullBody, isAlwaysCopyMessage, isAsyncConsumer, isAsyncStartListener, isAsyncStopListener, isAutoStartup, isDeliveryPersistent, isDisableReplyTo, isDisableTimeToLive, isEagerLoadingOfProperties, isErrorHandlerLogStackTrace, isExplicitQosEnabled, isExposeListenerSession, isForceSendOriginalMessage, isIncludeAllJMSXProperties, isIncludeSentJMSMessageID, isLazyCreateTransactionManager, isMapJmsMessage, isMessageIdEnabled, isMessageTimestampEnabled, isPreserveMessageQos, isPubSubNoLocal, isReplyToDeliveryPersistent, isSubscriptionDurable, isTestConnectionOnStartup, isTransacted, isTransactedInOut, isTransferException, isTransferExchange, isUseMessageIDAsCorrelationID, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAllowNullBody, setAlwaysCopyMessage, setAsyncConsumer, setAsyncStartListener, setAsyncStopListener, setAutoStartup, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConnectionFactory, setConsumerType, setDefaultTaskExecutorType, setDeliveryPersistent, setDestinationResolver, setDisableReplyTo, setDisableTimeToLive, setDurableSubscriptionName, setEagerLoadingOfProperties, setErrorHandler, setErrorHandlerLoggingLevel, setErrorHandlerLogStackTrace, setExceptionListener, setExplicitQosEnabled, setExposeListenerSession, setForceSendOriginalMessage, setIdleConsumerLimit, setIdleTaskExecutionLimit, setIncludeAllJMSXProperties, setIncludeSentJMSMessageID, setJmsKeyFormatStrategy, setJmsMessageType, setJmsOperations, setLazyCreateTransactionManager, setListenerConnectionFactory, setMapJmsMessage, setMaxConcurrentConsumers, setMaxMessagesPerTask, setMessageConverter, setMessageIdEnabled, setMessageListenerContainerFactory, setMessageTimestampEnabled, setMetadataJmsOperations, setPreserveMessageQos, setPriority, setProviderMetadata, setPubSubNoLocal, setReceiveTimeout, setRecoveryInterval, setReplyTo, setReplyToCacheLevelName, setReplyToDeliveryPersistent, setReplyToDestinationSelectorName, setReplyToType, setRequestTimeout, setRequestTimeoutCheckerInterval, setSubscriptionDurable, setTaskExecutor, setTemplateConnectionFactory, setTestConnectionOnStartup, setTimeToLive, setTransacted, setTransactedInOut, setTransactionManager, setTransactionName, setTransactionTimeout, setTransferException, setTransferExchange, setUseMessageIDAsCorrelationID, supportBlobMessage
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveMQConfiguration

public ActiveMQConfiguration()
Method Detail

getBrokerURL

public String getBrokerURL()

setBrokerURL

public void setBrokerURL(String brokerURL)
Sets the broker URL to use to connect to ActiveMQ using the ActiveMQ URI format

Parameters:
brokerURL - the URL of the broker.

isUseSingleConnection

public boolean isUseSingleConnection()

getUserName

public String getUserName()

setUserName

public void setUserName(String userName)
Sets the username to be used to login to ActiveMQ

Parameters:
userName -

getPassword

public String getPassword()

setPassword

public void setPassword(String password)
Sets the password/passcode used to login to ActiveMQ

Parameters:
password -

setUseSingleConnection

public void setUseSingleConnection(boolean useSingleConnection)
Enables or disables whether a Spring SingleConnectionFactory will be used so that when messages are sent to ActiveMQ from outside of a message consuming thread, pooling will be used rather than the default with the Spring JmsTemplate which will create a new connection, session, producer for each message then close them all down again.

The default value is true so that a single connection is used by default.

Parameters:
useSingleConnection -

isUsePooledConnection

public boolean isUsePooledConnection()

setUsePooledConnection

public void setUsePooledConnection(boolean usePooledConnection)
Enables or disables whether a PooledConnectionFactory will be used so that when messages are sent to ActiveMQ from outside of a message consuming thread, pooling will be used rather than the default with the Spring JmsTemplate which will create a new connection, session, producer for each message then close them all down again.

The default value is false by default as it requires an extra dependency on commons-pool.


createTransactionManager

protected org.springframework.transaction.PlatformTransactionManager createTransactionManager()
Factory method to create a default transaction manager if one is not specified

Overrides:
createTransactionManager in class org.apache.camel.component.jms.JmsConfiguration

setActiveMQComponent

protected void setActiveMQComponent(ActiveMQComponent activeMQComponent)

createConnectionFactory

protected ConnectionFactory createConnectionFactory()
Overrides:
createConnectionFactory in class org.apache.camel.component.jms.JmsConfiguration

createPooledConnectionFactory

protected ConnectionFactory createPooledConnectionFactory(ActiveMQConnectionFactory connectionFactory)

loadClass

public static Class<?> loadClass(String name,
                                 ClassLoader loader)
                          throws ClassNotFoundException
Throws:
ClassNotFoundException


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.