Class SharedQueueMessageListenerContainer
- java.lang.Object
-
- org.springframework.jms.support.JmsAccessor
-
- org.springframework.jms.support.destination.JmsDestinationAccessor
-
- org.springframework.jms.listener.AbstractJmsListeningContainer
-
- org.springframework.jms.listener.AbstractMessageListenerContainer
-
- org.springframework.jms.listener.AbstractPollingMessageListenerContainer
-
- org.springframework.jms.listener.DefaultMessageListenerContainer
-
- org.apache.camel.component.jms.DefaultJmsMessageListenerContainer
-
- org.apache.camel.component.jms.reply.SharedQueueMessageListenerContainer
-
- All Implemented Interfaces:
org.springframework.beans.factory.Aware
,org.springframework.beans.factory.BeanNameAware
,org.springframework.beans.factory.DisposableBean
,org.springframework.beans.factory.InitializingBean
,org.springframework.context.Lifecycle
,org.springframework.context.Phased
,org.springframework.context.SmartLifecycle
,org.springframework.jms.listener.MessageListenerContainer
public class SharedQueueMessageListenerContainer extends DefaultJmsMessageListenerContainer
ThisDefaultMessageListenerContainer
is used for reply queues which are shared. This implementation supports using a fixed or dynamic JMS Message Selector to pickup the designated reply messages from the shared queue. Since the queue is shared, then we can only pickup the reply messages which is intended for us, so to support that we must use JMS Message Selectors. See more details at camel-jms.- See Also:
ExclusiveQueueMessageListenerContainer
-
-
Field Summary
-
Fields inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer
CACHE_AUTO, CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION, DEFAULT_RECOVERY_INTERVAL, DEFAULT_THREAD_NAME_PREFIX
-
Fields inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
DEFAULT_RECEIVE_TIMEOUT
-
Fields inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer
lifecycleMonitor, sharedConnectionMonitor
-
-
Constructor Summary
Constructors Constructor Description SharedQueueMessageListenerContainer(JmsEndpoint endpoint, String fixedMessageSelector)
Use a fixed JMS message selectorSharedQueueMessageListenerContainer(JmsEndpoint endpoint, MessageSelectorCreator creator)
Use a dynamic JMS message selector
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getMessageSelector()
-
Methods inherited from class org.apache.camel.component.jms.DefaultJmsMessageListenerContainer
createDefaultTaskExecutor, destroy, isAllowQuickStop, runningAllowed, stop, stopSharedConnection
-
Methods inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer
applyBackOffTime, doInitialize, doRescheduleTask, doShutdown, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleConsumerLimit, getIdleReceivesPerTaskLimit, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, isRecovering, isRegisteredWithDestination, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshConnectionUntilSuccessful, refreshDestination, scheduleNewInvokerIfAppropriate, setBackOff, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleConsumerLimit, setIdleReceivesPerTaskLimit, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, start, startSharedConnection, stop
-
Methods inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
createListenerConsumer, doReceiveAndExecute, getConnection, getReceiveTimeout, getSession, getTransactionManager, isSessionLocallyTransacted, receiveAndExecute, receiveMessage, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceived
-
Methods inherited from class org.springframework.jms.listener.AbstractMessageListenerContainer
checkMessageListener, commitIfNecessary, createConsumer, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getErrorHandler, getExceptionListener, getMessageConverter, getMessageListener, getReplyQosSettings, getSubscriptionName, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isPubSubNoLocal, isReplyPubSubDomain, isSubscriptionDurable, isSubscriptionShared, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageConverter, setMessageListener, setMessageSelector, setPubSubNoLocal, setReplyPubSubDomain, setReplyQosSettings, setSubscriptionDurable, setSubscriptionName, setSubscriptionShared, setupMessageListener, validateConfiguration
-
Methods inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer
afterPropertiesSet, createSharedConnection, doStart, doStop, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, isActive, isAutoStartup, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, setAutoStartup, setBeanName, setClientId, setPhase, shutdown
-
Methods inherited from class org.springframework.jms.support.destination.JmsDestinationAccessor
getDestinationResolver, isPubSubDomain, receiveFromConsumer, resolveDestinationName, setDestinationResolver, setPubSubDomain
-
Methods inherited from class org.springframework.jms.support.JmsAccessor
convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, obtainConnectionFactory, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Constructor Detail
-
SharedQueueMessageListenerContainer
public SharedQueueMessageListenerContainer(JmsEndpoint endpoint, String fixedMessageSelector)
Use a fixed JMS message selector- Parameters:
endpoint
- the endpointfixedMessageSelector
- the fixed selector
-
SharedQueueMessageListenerContainer
public SharedQueueMessageListenerContainer(JmsEndpoint endpoint, MessageSelectorCreator creator)
Use a dynamic JMS message selector- Parameters:
endpoint
- the endpointcreator
- the create to create the dynamic selector
-
-
Method Detail
-
getMessageSelector
public String getMessageSelector()
- Overrides:
getMessageSelector
in classorg.springframework.jms.listener.AbstractMessageListenerContainer
-
-