org.apache.activemq.camel.component
Class ActiveMQComponent

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultComponent
          extended by org.apache.camel.impl.UriEndpointComponent
              extended by org.apache.camel.component.jms.JmsComponent
                  extended by org.apache.activemq.camel.component.ActiveMQComponent
All Implemented Interfaces:
org.apache.camel.CamelContextAware, org.apache.camel.Component, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.EndpointCompleter, org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class ActiveMQComponent
extends org.apache.camel.component.jms.JmsComponent
implements org.apache.camel.spi.EndpointCompleter

The ActiveMQ Component


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
ActiveMQComponent()
           
ActiveMQComponent(ActiveMQConfiguration configuration)
           
ActiveMQComponent(org.apache.camel.CamelContext context)
           
 
Method Summary
static ActiveMQComponent activeMQComponent()
          Creates an ActiveMQ Component
static ActiveMQComponent activeMQComponent(String brokerURL)
          Creates an ActiveMQ Component connecting to the given broker URL
protected  void addPooledConnectionFactoryService(Service pooledConnectionFactoryService)
           
protected  void addSingleConnectionFactory(org.springframework.jms.connection.SingleConnectionFactory singleConnectionFactory)
           
 List<String> completeEndpointPath(org.apache.camel.ComponentConfiguration componentConfiguration, String completionText)
           
protected  String convertPathToActualDestination(String path, Map<String,Object> parameters)
           
protected  org.apache.camel.component.jms.JmsConfiguration createConfiguration()
           
protected  void createDestinationSource()
           
protected  void doStart()
           
protected  void doStop()
           
 boolean isExposeAllQueues()
           
 void setBrokerURL(String brokerURL)
           
 void setConfiguration(org.apache.camel.component.jms.JmsConfiguration configuration)
           
 void setExposeAllQueues(boolean exposeAllQueues)
          If enabled this will cause all Queues in the ActiveMQ broker to be eagerly populated into the CamelContext so that they can be easily browsed by any Camel tooling.
 void setPassword(String password)
           
 void setUsePooledConnection(boolean usePooledConnection)
           
 void setUserName(String userName)
           
 void setUseSingleConnection(boolean useSingleConnection)
           
 
Methods inherited from class org.apache.camel.component.jms.JmsComponent
createEndpoint, doShutdown, getAsyncStartStopExecutorService, getConfiguration, getHeaderFilterStrategy, getQueueBrowseStrategy, jmsComponent, jmsComponent, jmsComponent, jmsComponentAutoAcknowledge, jmsComponentClientAcknowledge, jmsComponentTransacted, jmsComponentTransacted, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAllowNullBody, setAlwaysCopyMessage, setApplicationContext, setAsyncConsumer, setAsyncStartListener, setAsyncStopListener, setAutoStartup, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConnectionFactory, setDefaultTaskExecutorType, setDeliveryPersistent, setDestinationResolver, setDurableSubscriptionName, setEagerLoadingOfProperties, setErrorHandler, setErrorHandlerLoggingLevel, setErrorHandlerLogStackTrace, setExceptionListener, setExplicitQosEnabled, setExposeListenerSession, setForceSendOriginalMessage, setHeaderFilterStrategy, setIdleConsumerLimit, setIdleTaskExecutionLimit, setIncludeAllJMSXProperties, setIncludeSentJMSMessageID, setJmsKeyFormatStrategy, setJmsKeyFormatStrategy, setJmsOperations, setLazyCreateTransactionManager, setMapJmsMessage, setMaxConcurrentConsumers, setMaxMessagesPerTask, setMessageConverter, setMessageIdEnabled, setMessageTimestampEnabled, setPreserveMessageQos, setPriority, setPubSubNoLocal, setQueueBrowseStrategy, setReceiveTimeout, setRecoveryInterval, setReplyToCacheLevelName, setReplyToType, setRequestTimeout, setRequestTimeoutCheckerInterval, setSubscriptionDurable, setTaskExecutor, setTestConnectionOnStartup, setTimeToLive, setTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, setTransferException, setTransferExchange, setUseMessageIDAsCorrelationID
 
Methods inherited from class org.apache.camel.impl.UriEndpointComponent
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap
 
Methods inherited from class org.apache.camel.impl.DefaultComponent
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveMQComponent

public ActiveMQComponent()

ActiveMQComponent

public ActiveMQComponent(org.apache.camel.CamelContext context)

ActiveMQComponent

public ActiveMQComponent(ActiveMQConfiguration configuration)
Method Detail

activeMQComponent

public static ActiveMQComponent activeMQComponent()
Creates an ActiveMQ Component

Returns:
the created component

activeMQComponent

public static ActiveMQComponent activeMQComponent(String brokerURL)
Creates an ActiveMQ Component connecting to the given broker URL

Parameters:
brokerURL - the URL to connect to
Returns:
the created component

setBrokerURL

public void setBrokerURL(String brokerURL)

setUserName

public void setUserName(String userName)

setPassword

public void setPassword(String password)

isExposeAllQueues

public boolean isExposeAllQueues()

setExposeAllQueues

public void setExposeAllQueues(boolean exposeAllQueues)
If enabled this will cause all Queues in the ActiveMQ broker to be eagerly populated into the CamelContext so that they can be easily browsed by any Camel tooling. This option is disabled by default.

Parameters:
exposeAllQueues -

setUsePooledConnection

public void setUsePooledConnection(boolean usePooledConnection)

setUseSingleConnection

public void setUseSingleConnection(boolean useSingleConnection)

addPooledConnectionFactoryService

protected void addPooledConnectionFactoryService(Service pooledConnectionFactoryService)

addSingleConnectionFactory

protected void addSingleConnectionFactory(org.springframework.jms.connection.SingleConnectionFactory singleConnectionFactory)

convertPathToActualDestination

protected String convertPathToActualDestination(String path,
                                                Map<String,Object> parameters)
Overrides:
convertPathToActualDestination in class org.apache.camel.component.jms.JmsComponent

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.component.jms.JmsComponent
Throws:
Exception

createDestinationSource

protected void createDestinationSource()

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.DefaultComponent
Throws:
Exception

setConfiguration

public void setConfiguration(org.apache.camel.component.jms.JmsConfiguration configuration)
Overrides:
setConfiguration in class org.apache.camel.component.jms.JmsComponent

createConfiguration

protected org.apache.camel.component.jms.JmsConfiguration createConfiguration()
Overrides:
createConfiguration in class org.apache.camel.component.jms.JmsComponent

completeEndpointPath

public List<String> completeEndpointPath(org.apache.camel.ComponentConfiguration componentConfiguration,
                                         String completionText)
Specified by:
completeEndpointPath in interface org.apache.camel.spi.EndpointCompleter


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