DefaultMessageListenerContainer@Deprecated public class DefaultMessageListenerContainer102 extends DefaultMessageListenerContainer
DefaultMessageListenerContainer for the JMS 1.0.2 specification,
not relying on JMS 1.1 methods like SimpleMessageListenerContainer itself.
This class can be used for JMS 1.0.2 providers, offering the same facility as DefaultMessageListenerContainer does for JMS 1.1 providers.
AbstractJmsListeningContainer.SharedConnectionNotInitializedExceptionCACHE_AUTO, CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION, DEFAULT_RECOVERY_INTERVAL, DEFAULT_THREAD_NAME_PREFIXDEFAULT_RECEIVE_TIMEOUTlifecycleMonitor, sharedConnectionMonitorlogger| Constructor and Description |
|---|
DefaultMessageListenerContainer102()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
protected Connection |
createConnection()
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected MessageConsumer |
createConsumer(Session session,
Destination destination)
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected Session |
createSession(Connection con)
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected Connection |
getConnection(JmsResourceHolder holder)
Deprecated.
This implementation overrides the superclass method to accept either
a QueueConnection or a TopicConnection, depending on the domain.
|
protected Session |
getSession(JmsResourceHolder holder)
Deprecated.
This implementation overrides the superclass method to accept either
a QueueSession or a TopicSession, depending on the domain.
|
protected boolean |
isClientAcknowledge(Session session)
Deprecated.
This implementation overrides the superclass method to avoid using
JMS 1.1's Session
getAcknowledgeMode() method. |
createDefaultTaskExecutor, doInitialize, doRescheduleTask, doShutdown, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleConsumerLimit, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, isRecovering, isRegisteredWithDestination, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshConnectionUntilSuccessful, refreshDestination, scheduleNewInvokerIfAppropriate, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleConsumerLimit, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, sleepInbetweenRecoveryAttempts, start, startSharedConnection, stop, stopSharedConnectioncreateListenerConsumer, doReceiveAndExecute, getTransactionManager, isPubSubNoLocal, isSessionLocallyTransacted, receiveAndExecute, receiveMessage, setPubSubNoLocal, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceivedcheckMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, getMessageSelector, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable, validateConfigurationafterPropertiesSet, createSharedConnection, destroy, doStart, doStop, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, isActive, isAutoStartup, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, setPhase, shutdown, stopgetDestinationResolver, isPubSubDomain, resolveDestinationName, setDestinationResolver, setPubSubDomainconvertJmsAccessException, getConnectionFactory, getSessionAcknowledgeMode, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeNamepublic DefaultMessageListenerContainer102()
protected Connection getConnection(JmsResourceHolder holder)
getConnection in class AbstractPollingMessageListenerContainerholder - the JmsResourceHoldernull if none foundprotected Session getSession(JmsResourceHolder holder)
getSession in class AbstractPollingMessageListenerContainerholder - the JmsResourceHoldernull if none foundprotected Connection createConnection() throws JMSException
createConnection in class JmsAccessorJMSException - if thrown by JMS API methodsConnectionFactory.createConnection()protected Session createSession(Connection con) throws JMSException
createSession in class JmsAccessorcon - the JMS Connection to create a Session forJMSException - if thrown by JMS API methodsConnection.createSession(boolean, int)protected MessageConsumer createConsumer(Session session, Destination destination) throws JMSException
createConsumer in class AbstractPollingMessageListenerContainersession - the JMS Session to create a MessageConsumer fordestination - the JMS Destination to create a MessageConsumer forJMSException - if thrown by JMS API methodsprotected boolean isClientAcknowledge(Session session) throws JMSException
getAcknowledgeMode() method.
The best we can do here is to check the setting on the listener container.isClientAcknowledge in class JmsAccessorsession - the JMS Session to checkJMSException - if thrown by JMS API methodsSession.getAcknowledgeMode(),
Session.CLIENT_ACKNOWLEDGE