org.apache.camel.component.jms
Class JmsTemporaryTopicEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.component.jms.JmsEndpoint
              extended by org.apache.camel.component.jms.JmsTemporaryTopicEndpoint
All Implemented Interfaces:
org.apache.camel.CamelContextAware, DestinationEndpoint, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class JmsTemporaryTopicEndpoint
extends JmsEndpoint
implements DestinationEndpoint

A JMS Endpoint for working with a TemporaryTopic

Important: Need to be really careful to always use the same Connection otherwise the destination goes stale

Version:

Field Summary
 
Fields inherited from class org.apache.camel.component.jms.JmsEndpoint
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
JmsTemporaryTopicEndpoint(String uri, JmsComponent component, String destination, JmsConfiguration configuration)
           
JmsTemporaryTopicEndpoint(String endpointUri, String destination)
           
JmsTemporaryTopicEndpoint(javax.jms.TemporaryTopic jmsDestination)
           
 
Method Summary
protected  javax.jms.Destination createJmsDestination(javax.jms.Session session)
           
 javax.jms.Destination getJmsDestination(javax.jms.Session session)
           
 boolean isSingleton()
          This endpoint is a singleton so that the temporary destination instances are shared across all producers and consumers of the same endpoint URI
 
Methods inherited from class org.apache.camel.component.jms.JmsEndpoint
configureListenerContainer, createConsumer, createConsumer, createEndpointUri, createExchange, createExchange, createInOnlyTemplate, createInOutTemplate, createMessageListenerContainer, createPollingConsumer, createProducer, getAcknowledgementMode, getAcknowledgementModeName, getAsyncStartStopExecutorService, getBinding, getCacheLevel, getCacheLevelName, getCamelId, getCamelManagementName, getClientId, getComponent, getConcurrentConsumers, getConfiguration, getConnectionFactory, getDefaultTaskExecutorType, getDeliveryMode, getDestination, getDestinationName, getDestinationResolver, getDurableSubscriptionName, getEndpointConfiguredDestinationName, getEndpointUri, getErrorHandler, getErrorHandlerLoggingLevel, getExceptionListener, getHeaderFilterStrategy, getIdleConsumerLimit, getIdleTaskExecutionLimit, getJmsKeyFormatStrategy, getJmsMessageType, getJmsOperations, getListenerConnectionFactory, getMaxConcurrentConsumers, getMaxMessagesPerTask, getMessageConverter, getMessageListenerContainerFactory, getMetadataJmsOperations, getMetadataJmsOperations, getPriority, getProviderMetadata, getReceiveTimeout, getRecoveryInterval, getReplyTo, getReplyToCacheLevelName, getReplyToDestinationSelectorName, getReplyToType, getRequestTimeout, getRequestTimeoutCheckerInterval, getRunningMessageListeners, getSelector, getState, getTaskExecutor, getTemplateConnectionFactory, getTemporaryQueueType, getTemporaryTopicType, getThreadName, getTimeToLive, getTransactionManager, getTransactionName, getTransactionTimeout, isAcceptMessagesWhileStopping, isAllowNullBody, isAlwaysCopyMessage, isAsyncConsumer, isAsyncStartListener, isAsyncStopListener, isAutoStartup, isDeliveryPersistent, isDisableReplyTo, isDisableTimeToLive, isEagerLoadingOfProperties, isErrorHandlerLogStackTrace, isExplicitQosEnabled, isExposeListenerSession, isForceSendOriginalMessage, isIncludeAllJMSXProperties, isIncludeSentJMSMessageID, isLazyCreateTransactionManager, isMessageIdEnabled, isMessageTimestampEnabled, isMultipleConsumersSupported, isPreserveMessageQos, isPubSubDomain, isPubSubNoLocal, isReplyToDeliveryPersistent, isRunning, isSubscriptionDurable, isTestConnectionOnStartup, isTransacted, isTransactedInOut, isTransferException, isTransferExchange, isUseMessageIDAsCorrelationID, newInstance, newInstance, onListenerContainerStarting, onListenerContainerStopped, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAllowNullBody, setAlwaysCopyMessage, setAsyncConsumer, setAsyncStartListener, setAsyncStopListener, setAutoStartup, setBinding, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConfiguration, setConnectionFactory, setDefaultTaskExecutorType, setDeliveryMode, setDeliveryPersistent, setDestination, setDestinationName, setDestinationResolver, setDisableReplyTo, setDisableTimeToLive, setDurableSubscriptionName, setEagerLoadingOfProperties, setErrorHandler, setErrorHandlerLogStackTrace, setExceptionListener, setExplicitQosEnabled, setExposeListenerSession, setForceSendOriginalMessage, setHeaderFilterStrategy, setIdleConsumerLimit, setIdleTaskExecutionLimit, setIncludeAllJMSXProperties, setIncludeSentJMSMessageID, setJmsKeyFormatStrategy, setJmsMessageType, setJmsOperations, setLazyCreateTransactionManager, setListenerConnectionFactory, setMaxConcurrentConsumers, setMaxMessagesPerTask, setMessageConverter, setMessageIdEnabled, setMessageListenerContainerFactory, setMessageTimestampEnabled, setMetadataJmsOperations, setPreserveMessageQos, setPriority, setProviderMetadata, setPubSubNoLocal, setReceiveTimeout, setRecoveryInterval, setReplyTo, setReplyToCacheLevelName, setReplyToDeliveryPersistent, setReplyToDestinationSelectorName, setReplyToType, setRequestTimeout, setSelector, setSubscriptionDurable, setTaskExecutor, setTemplateConnectionFactory, setTestConnectionOnStartup, setTimeToLive, setTransacted, setTransactedInOut, setTransactionManager, setTransactionName, setTransactionTimeout, setTransferException, setTransferExchange, setUseMessageIDAsCorrelationID, shutdown, stop
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createExchange, createExchange, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, start, suspend
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start
 

Constructor Detail

JmsTemporaryTopicEndpoint

public JmsTemporaryTopicEndpoint(String uri,
                                 JmsComponent component,
                                 String destination,
                                 JmsConfiguration configuration)

JmsTemporaryTopicEndpoint

public JmsTemporaryTopicEndpoint(String endpointUri,
                                 String destination)

JmsTemporaryTopicEndpoint

public JmsTemporaryTopicEndpoint(javax.jms.TemporaryTopic jmsDestination)
                          throws javax.jms.JMSException
Throws:
javax.jms.JMSException
Method Detail

isSingleton

public boolean isSingleton()
This endpoint is a singleton so that the temporary destination instances are shared across all producers and consumers of the same endpoint URI

Specified by:
isSingleton in interface org.apache.camel.IsSingleton
Overrides:
isSingleton in class JmsEndpoint
Returns:
true

getJmsDestination

public javax.jms.Destination getJmsDestination(javax.jms.Session session)
                                        throws javax.jms.JMSException
Specified by:
getJmsDestination in interface DestinationEndpoint
Throws:
javax.jms.JMSException

createJmsDestination

protected javax.jms.Destination createJmsDestination(javax.jms.Session session)
                                              throws javax.jms.JMSException
Throws:
javax.jms.JMSException


Apache Camel