public class SharedQueueMessageListenerContainer extends DefaultJmsMessageListenerContainer
DefaultMessageListenerContainer
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.CACHE_AUTO, CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION, DEFAULT_RECOVERY_INTERVAL, DEFAULT_THREAD_NAME_PREFIX
DEFAULT_RECEIVE_TIMEOUT
Constructor and Description |
---|
SharedQueueMessageListenerContainer(JmsEndpoint endpoint,
MessageSelectorCreator creator)
Use a dynamic JMS message selector
|
SharedQueueMessageListenerContainer(JmsEndpoint endpoint,
String fixedMessageSelector)
Use a fixed JMS message selector
|
Modifier and Type | Method and Description |
---|---|
String |
getMessageSelector() |
createDefaultTaskExecutor, destroy, isAllowQuickStop, refreshConnectionUntilSuccessful, runningAllowed, sleepInbetweenRecoveryAttempts, stop, stopSharedConnection
doInitialize, doRescheduleTask, doShutdown, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleConsumerLimit, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, isRecovering, isRegisteredWithDestination, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshDestination, scheduleNewInvokerIfAppropriate, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleConsumerLimit, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, start, startSharedConnection, stop
createConsumer, createListenerConsumer, doReceiveAndExecute, getConnection, getSession, getTransactionManager, isPubSubNoLocal, isSessionLocallyTransacted, receiveAndExecute, receiveMessage, setPubSubNoLocal, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceived
checkMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable, validateConfiguration
afterPropertiesSet, createSharedConnection, doStart, doStop, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, isActive, isAutoStartup, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, setAutoStartup, setBeanName, setClientId, setPhase, shutdown
getDestinationResolver, isPubSubDomain, resolveDestinationName, setDestinationResolver, setPubSubDomain
convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName
public SharedQueueMessageListenerContainer(JmsEndpoint endpoint, String fixedMessageSelector)
endpoint
- the endpointfixedMessageSelector
- the fixed selectorpublic SharedQueueMessageListenerContainer(JmsEndpoint endpoint, MessageSelectorCreator creator)
endpoint
- the endpointcreator
- the create to create the dynamic selectorpublic String getMessageSelector()
getMessageSelector
in class org.springframework.jms.listener.AbstractMessageListenerContainer
Apache Camel