org.springframework.jms.listener
Class DefaultMessageListenerContainer102
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.springframework.jms.listener.DefaultMessageListenerContainer102
- All Implemented Interfaces:
- BeanNameAware, DisposableBean, InitializingBean, Lifecycle, Phased, SmartLifecycle
Deprecated. as of Spring 3.0, in favor of the JMS 1.1 based DefaultMessageListenerContainer
@Deprecated
public class DefaultMessageListenerContainer102
- extends DefaultMessageListenerContainer
A subclass of 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.
- Since:
- 2.0
- Author:
- Juergen Hoeller
Method Summary |
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. |
Methods inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer |
createDefaultTaskExecutor, doInitialize, doRescheduleTask, doShutdown, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshConnectionUntilSuccessful, refreshDestination, scheduleNewInvokerIfAppropriate, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, sleepInbetweenRecoveryAttempts, start, startSharedConnection, stop, stopSharedConnection, validateConfiguration |
Methods inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer |
createListenerConsumer, doReceiveAndExecute, getTransactionManager, isPubSubNoLocal, isSessionLocallyTransacted, receiveAndExecute, receiveMessage, setPubSubNoLocal, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout |
Methods inherited from class org.springframework.jms.listener.AbstractMessageListenerContainer |
checkMessageListener, 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 |
Methods inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer |
afterPropertiesSet, createSharedConnection, destroy, doStart, doStop, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, isActive, isAutoStartup, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, setPhase, shutdown, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultMessageListenerContainer102
public DefaultMessageListenerContainer102()
- Deprecated.
getConnection
protected Connection getConnection(JmsResourceHolder holder)
- Deprecated.
- This implementation overrides the superclass method to accept either
a QueueConnection or a TopicConnection, depending on the domain.
- Overrides:
getConnection
in class AbstractPollingMessageListenerContainer
- Parameters:
holder
- the JmsResourceHolder
- Returns:
- an appropriate Connection fetched from the holder,
or
null
if none found
getSession
protected Session getSession(JmsResourceHolder holder)
- Deprecated.
- This implementation overrides the superclass method to accept either
a QueueSession or a TopicSession, depending on the domain.
- Overrides:
getSession
in class AbstractPollingMessageListenerContainer
- Parameters:
holder
- the JmsResourceHolder
- Returns:
- an appropriate Session fetched from the holder,
or
null
if none found
createConnection
protected Connection createConnection()
throws JMSException
- Deprecated.
- This implementation overrides the superclass method to use JMS 1.0.2 API.
- Overrides:
createConnection
in class JmsAccessor
- Returns:
- the new JMS Connection
- Throws:
JMSException
- if thrown by JMS API methods- See Also:
ConnectionFactory.createConnection()
createSession
protected Session createSession(Connection con)
throws JMSException
- Deprecated.
- This implementation overrides the superclass method to use JMS 1.0.2 API.
- Overrides:
createSession
in class JmsAccessor
- Parameters:
con
- the JMS Connection to create a Session for
- Returns:
- the new JMS Session
- Throws:
JMSException
- if thrown by JMS API methods- See Also:
Connection.createSession(boolean, int)
createConsumer
protected MessageConsumer createConsumer(Session session,
Destination destination)
throws JMSException
- Deprecated.
- This implementation overrides the superclass method to use JMS 1.0.2 API.
- Overrides:
createConsumer
in class AbstractPollingMessageListenerContainer
- Parameters:
session
- the JMS Session to create a MessageConsumer fordestination
- the JMS Destination to create a MessageConsumer for
- Returns:
- the new JMS MessageConsumer
- Throws:
JMSException
- if thrown by JMS API methods
isClientAcknowledge
protected boolean isClientAcknowledge(Session session)
throws JMSException
- Deprecated.
- This implementation overrides the superclass method to avoid using
JMS 1.1's Session
getAcknowledgeMode()
method.
The best we can do here is to check the setting on the listener container.
- Overrides:
isClientAcknowledge
in class JmsAccessor
- Parameters:
session
- the JMS Session to check
- Returns:
- whether the given Session is in client acknowledge mode
- Throws:
JMSException
- if thrown by JMS API methods- See Also:
Session.getAcknowledgeMode()
,
Session.CLIENT_ACKNOWLEDGE