org.springframework.jms.listener: public class: SimpleMessageListenerContainer102

org.springframework.jms.listener
public class: SimpleMessageListenerContainer102 [javadoc | source]

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.SimpleMessageListenerContainer
                  org.springframework.jms.listener.SimpleMessageListenerContainer102

All Implemented Interfaces:
javax.jms.ExceptionListener, DisposableBean, BeanNameAware, Lifecycle, InitializingBean

A subclass of 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.

author: Juergen - Hoeller

since: 2.0 -

Fields inherited from org.springframework.jms.listener.AbstractJmsListeningContainer:
sharedConnectionMonitor, lifecycleMonitor

Fields inherited from org.springframework.jms.support.JmsAccessor:
logger

Method from org.springframework.jms.listener.SimpleMessageListenerContainer102 Summary:
createConnection, createConsumer, createSession, isClientAcknowledge

Methods from org.springframework.jms.listener.SimpleMessageListenerContainer:
createConsumer, createListenerConsumer, doInitialize, doShutdown, doStart, initializeConsumers, isPubSubNoLocal, onException, prepareSharedConnection, processMessage, setConcurrentConsumers, setPubSubNoLocal, setTaskExecutor, sharedConnectionEnabled, validateConfiguration

Methods from org.springframework.jms.listener.AbstractMessageListenerContainer:
checkMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDestination, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, getMessageSelector, handleListenerException, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSessionLocallyTransacted, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable, validateConfiguration

Methods from org.springframework.jms.listener.AbstractMessageListenerContainer:

checkMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDestination, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, getMessageSelector, handleListenerException, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSessionLocallyTransacted, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable, validateConfiguration

Methods from org.springframework.jms.listener.AbstractJmsListeningContainer:
afterPropertiesSet, createSharedConnection, destroy, doInitialize, doRescheduleTask, doShutdown, doStart, doStop, establishSharedConnection, getBeanName, getClientId, getPausedTaskCount, getSharedConnection, initialize, isActive, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, sharedConnectionEnabled, shutdown, start, startSharedConnection, stop, stopSharedConnection, validateConfiguration, waitWhileNotRunning

Methods from org.springframework.jms.listener.AbstractJmsListeningContainer:

afterPropertiesSet, createSharedConnection, destroy, doInitialize, doRescheduleTask, doShutdown, doStart, doStop, establishSharedConnection, getBeanName, getClientId, getPausedTaskCount, getSharedConnection, initialize, isActive, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, sharedConnectionEnabled, shutdown, start, startSharedConnection, stop, stopSharedConnection, validateConfiguration, waitWhileNotRunning

Methods from org.springframework.jms.support.destination.JmsDestinationAccessor:
getDestinationResolver, isPubSubDomain, resolveDestinationName, setDestinationResolver, setPubSubDomain

Methods from org.springframework.jms.support.JmsAccessor:
afterPropertiesSet, convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName, setSessionTransacted

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.springframework.jms.listener.SimpleMessageListenerContainer102 Detail:
protected Connection createConnection() throws JMSException { if (isPubSubDomain()) { return ((TopicConnectionFactory) getConnectionFactory()).createTopicConnection(); } else { return ((QueueConnectionFactory) getConnectionFactory()).createQueueConnection(); } } This implementation overrides the superclass method to use JMS 1.0.2 API.
protected MessageConsumer createConsumer(Session session, Destination destination) throws JMSException { if (isPubSubDomain()) { if (isSubscriptionDurable()) { return ((TopicSession) session).createDurableSubscriber( (Topic) destination, getDurableSubscriptionName(), getMessageSelector(), isPubSubNoLocal()); } else { return ((TopicSession) session).createSubscriber( (Topic) destination, getMessageSelector(), isPubSubNoLocal()); } } else { return ((QueueSession) session).createReceiver((Queue) destination, getMessageSelector()); } } This implementation overrides the superclass method to use JMS 1.0.2 API.
protected Session createSession(Connection con) throws JMSException { if (isPubSubDomain()) { return ((TopicConnection) con).createTopicSession(isSessionTransacted(), getSessionAcknowledgeMode()); } else { return ((QueueConnection) con).createQueueSession(isSessionTransacted(), getSessionAcknowledgeMode()); } } This implementation overrides the superclass method to use JMS 1.0.2 API.
protected boolean isClientAcknowledge(Session session) throws JMSException { return (getSessionAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE); } 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.

Method from org.springframework.jms.listener.SimpleMessageListenerContainer102 Detail:

 protected Connection createConnection() throws JMSException {
		if (isPubSubDomain()) {
			return ((TopicConnectionFactory) getConnectionFactory()).createTopicConnection();
		}
		else {
			return ((QueueConnectionFactory) getConnectionFactory()).createQueueConnection();
		}
}

This implementation overrides the superclass method to use JMS 1.0.2 API.

 protected MessageConsumer createConsumer(Session session,
    Destination destination) throws JMSException {
		if (isPubSubDomain()) {
			if (isSubscriptionDurable()) {
				return ((TopicSession) session).createDurableSubscriber(
						(Topic) destination, getDurableSubscriptionName(), getMessageSelector(), isPubSubNoLocal());
			}
			else {
				return ((TopicSession) session).createSubscriber(
						(Topic) destination, getMessageSelector(), isPubSubNoLocal());
			}
		}
		else {
			return ((QueueSession) session).createReceiver((Queue) destination, getMessageSelector());
		}
}

This implementation overrides the superclass method to use JMS 1.0.2 API.

 protected Session createSession(Connection con) throws JMSException {
		if (isPubSubDomain()) {
			return ((TopicConnection) con).createTopicSession(isSessionTransacted(), getSessionAcknowledgeMode());
		}
		else {
			return ((QueueConnection) con).createQueueSession(isSessionTransacted(), getSessionAcknowledgeMode());
		}
}

This implementation overrides the superclass method to use JMS 1.0.2 API.

 protected boolean isClientAcknowledge(Session session) throws JMSException {
		return (getSessionAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE);
}

getAcknowledgeMode()