SimpleMessageListenerContainer
@Deprecated public class SimpleMessageListenerContainer102 extends SimpleMessageListenerContainer
SimpleMessageListenerContainer
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 SimpleMessageListenerContainer does for JMS 1.1 providers.
AbstractJmsListeningContainer.SharedConnectionNotInitializedException
lifecycleMonitor, sharedConnectionMonitor
logger
Constructor and Description |
---|
SimpleMessageListenerContainer102()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Connection |
createConnection()
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected javax.jms.MessageConsumer |
createConsumer(javax.jms.Session session,
javax.jms.Destination destination)
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected javax.jms.Session |
createSession(javax.jms.Connection con)
Deprecated.
This implementation overrides the superclass method to use JMS 1.0.2 API.
|
protected boolean |
isClientAcknowledge(javax.jms.Session session)
Deprecated.
This implementation overrides the superclass method to avoid using
JMS 1.1's Session
getAcknowledgeMode() method. |
createListenerConsumer, doInitialize, doShutdown, doStart, initializeConsumers, isPubSubNoLocal, onException, prepareSharedConnection, processMessage, setConcurrency, setConcurrentConsumers, setConnectLazily, setPubSubNoLocal, setTaskExecutor, sharedConnectionEnabled, validateConfiguration
checkMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, getMessageSelector, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSessionLocallyTransacted, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable
afterPropertiesSet, createSharedConnection, destroy, doRescheduleTask, doStop, establishSharedConnection, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, initialize, isActive, isAutoStartup, isRunning, logRejectedTask, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, setPhase, shutdown, start, startSharedConnection, stop, stop, stopSharedConnection
getDestinationResolver, isPubSubDomain, resolveDestinationName, setDestinationResolver, setPubSubDomain
convertJmsAccessException, getConnectionFactory, getSessionAcknowledgeMode, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName, setSessionTransacted
public SimpleMessageListenerContainer102()
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in class JmsAccessor
javax.jms.JMSException
- if thrown by JMS API methodsConnectionFactory.createConnection()
protected javax.jms.Session createSession(javax.jms.Connection con) throws javax.jms.JMSException
createSession
in class JmsAccessor
con
- the JMS Connection to create a Session forjavax.jms.JMSException
- if thrown by JMS API methodsConnection.createSession(boolean, int)
protected javax.jms.MessageConsumer createConsumer(javax.jms.Session session, javax.jms.Destination destination) throws javax.jms.JMSException
createConsumer
in class SimpleMessageListenerContainer
session
- the JMS Session to create a MessageConsumer fordestination
- the JMS Destination to create a MessageConsumer forjavax.jms.JMSException
- if thrown by JMS API methodsprotected boolean isClientAcknowledge(javax.jms.Session session) throws javax.jms.JMSException
getAcknowledgeMode()
method.
The best we can do here is to check the setting on the listener container.isClientAcknowledge
in class JmsAccessor
session
- the JMS Session to checkjavax.jms.JMSException
- if thrown by JMS API methodsSession.getAcknowledgeMode()
,
Session.CLIENT_ACKNOWLEDGE
Copyright © 2015. All rights reserved.