org.springframework.jms.listener.serversession: public class: ServerSessionMessageListenerContainer102

org.springframework.jms.listener.serversession
public class: ServerSessionMessageListenerContainer102 [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.serversession.ServerSessionMessageListenerContainer
                  org.springframework.jms.listener.serversession.ServerSessionMessageListenerContainer102

All Implemented Interfaces:
ListenerSessionManager, DisposableBean, BeanNameAware, Lifecycle, InitializingBean

Deprecated! as - of Spring 2.5, in favor of DefaultMessageListenerContainer and JmsMessageEndpointManager. To be removed in Spring 3.0.

A subclass of ServerSessionMessageListenerContainer for the JMS 1.0.2 specification, not relying on JMS 1.1 methods like ServerSessionMessageListenerContainer itself.

This class can be used for JMS 1.0.2 providers, offering the same facility as ServerSessionMessageListenerContainer 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.serversession.ServerSessionMessageListenerContainer102 Summary:
createConnection, createConsumer, createSession, isClientAcknowledge

Methods from org.springframework.jms.listener.serversession.ServerSessionMessageListenerContainer:
createConsumer, createListenerSession, createServerSessionPool, doInitialize, doShutdown, executeListenerSession, getConsumer, getMaxMessagesPerTask, getServerSessionFactory, setMaxMessagesPerTask, setServerSessionFactory, sharedConnectionEnabled

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.serversession.ServerSessionMessageListenerContainer102 Detail:
protected Connection createConnection() throws JMSException { if (isPubSubDomain()) { return ((TopicConnectionFactory) getConnectionFactory()).createTopicConnection(); } else { return ((QueueConnectionFactory) getConnectionFactory()).createQueueConnection(); } } Deprecated! This implementation overrides the superclass method to use JMS 1.0.2 API.
protected ConnectionConsumer createConsumer(Connection con, Destination destination, ServerSessionPool pool) throws JMSException { if (isPubSubDomain()) { if (isSubscriptionDurable()) { return ((TopicConnection) con).createDurableConnectionConsumer( (Topic) destination, getDurableSubscriptionName(), getMessageSelector(), pool, getMaxMessagesPerTask()); } else { return ((TopicConnection) con).createConnectionConsumer( (Topic) destination, getMessageSelector(), pool, getMaxMessagesPerTask()); } } else { return ((QueueConnection) con).createConnectionConsumer( (Queue) destination, getMessageSelector(), pool, getMaxMessagesPerTask()); } } Deprecated! 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()); } } Deprecated! 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); } 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.

Method from org.springframework.jms.listener.serversession.ServerSessionMessageListenerContainer102 Detail:

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

Deprecated!

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

 protected ConnectionConsumer createConsumer(Connection con,
    Destination destination,
    ServerSessionPool pool) throws JMSException {
		if (isPubSubDomain()) {
			if (isSubscriptionDurable()) {
				return ((TopicConnection) con).createDurableConnectionConsumer(
						(Topic) destination, getDurableSubscriptionName(), getMessageSelector(), pool, getMaxMessagesPerTask());
			}
			else {
				return ((TopicConnection) con).createConnectionConsumer(
						(Topic) destination, getMessageSelector(), pool, getMaxMessagesPerTask());
			}
		}
		else {
			return ((QueueConnection) con).createConnectionConsumer(
					(Queue) destination, getMessageSelector(), pool, getMaxMessagesPerTask());
		}
}

Deprecated!

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());
		}
}

Deprecated!

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);
}

Deprecated!

getAcknowledgeMode()