nl.nn.adapterframework.jms

Class IbisMessageListenerContainer

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

nl.nn.adapterframework.jms.IbisMessageListenerContainer

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.jms.listener.MessageListenerContainer

public class IbisMessageListenerContainer
extends org.springframework.jms.listener.DefaultMessageListenerContainer

Extend the DefaultMessageListenerContainer from Spring to add trace logging and make it possible to monitor the last poll finished time.

Author:

Niels Meijer, Jaco de Groot

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer

org.springframework.jms.listener.AbstractJmsListeningContainer.SharedConnectionNotInitializedException

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Fields inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer

CACHE_AUTO, CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION, DEFAULT_RECOVERY_INTERVAL, DEFAULT_THREAD_NAME_PREFIX

Fields inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

DEFAULT_RECEIVE_TIMEOUT

Fields inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer

lifecycleMonitor, sharedConnectionMonitor

Fields inherited from class org.springframework.jms.support.destination.JmsDestinationAccessor

RECEIVE_TIMEOUT_INDEFINITE_WAIT, RECEIVE_TIMEOUT_NO_WAIT

Fields inherited from class org.springframework.jms.support.JmsAccessor

logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
IbisMessageListenerContainer()

Method Summary

Modifier and Type	Method and Description
protected void	commitIfNecessary(javax.jms.Session session, javax.jms.Message message)
protected javax.jms.Connection	createConnection()
protected javax.jms.Session	createSession(javax.jms.Connection conn)
protected javax.jms.Connection	createSharedConnection()
protected boolean	doReceiveAndExecute(Object invoker, javax.jms.Session session, javax.jms.MessageConsumer consumer, org.springframework.transaction.TransactionStatus txStatus)
protected javax.jms.Connection	getConnection(org.springframework.jms.connection.JmsResourceHolder holder)
CredentialFactory	getCredentialFactory()
protected javax.jms.Session	getSession(org.springframework.jms.connection.JmsResourceHolder holder)
protected boolean	receiveAndExecute(Object asyncMessageListenerInvoker, javax.jms.Session session, javax.jms.MessageConsumer consumer)
void	setCredentialFactory(CredentialFactory credentialFactory)

Methods inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer

applyBackOffTime, createDefaultTaskExecutor, doInitialize, doRescheduleTask, doShutdown, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleConsumerLimit, getIdleReceivesPerTaskLimit, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, isRecovering, isRegisteredWithDestination, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshConnectionUntilSuccessful, refreshDestination, scheduleNewInvokerIfAppropriate, setBackOff, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleConsumerLimit, setIdleReceivesPerTaskLimit, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, start, startSharedConnection, stop, stopSharedConnection

Methods inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

createListenerConsumer, getReceiveTimeout, getTransactionManager, isSessionLocallyTransacted, receiveMessage, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceived

Methods inherited from class org.springframework.jms.listener.AbstractMessageListenerContainer

checkMessageListener, createConsumer, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getErrorHandler, getExceptionListener, getMessageConverter, getMessageListener, getMessageSelector, getReplyQosSettings, getSubscriptionName, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isPubSubNoLocal, isReplyPubSubDomain, isSubscriptionDurable, isSubscriptionShared, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageConverter, setMessageListener, setMessageSelector, setPubSubNoLocal, setReplyPubSubDomain, setReplyQosSettings, setSubscriptionDurable, setSubscriptionName, setSubscriptionShared, setupMessageListener, validateConfiguration

Methods inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer

afterPropertiesSet, 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 org.springframework.jms.support.destination.JmsDestinationAccessor

getDestinationResolver, isPubSubDomain, receiveFromConsumer, resolveDestinationName, setDestinationResolver, setPubSubDomain

Methods inherited from class org.springframework.jms.support.JmsAccessor

convertJmsAccessException, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, obtainConnectionFactory, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.jms.listener.MessageListenerContainer

getDestinationResolver, isPubSubDomain

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, isAutoStartup

Methods inherited from interface org.springframework.context.Lifecycle

isRunning, stop

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

IbisMessageListenerContainer

public IbisMessageListenerContainer()

Method Detail

createConnection

protected javax.jms.Connection createConnection()
                                         throws javax.jms.JMSException

Overrides:

createConnection in class org.springframework.jms.support.JmsAccessor

Throws:

javax.jms.JMSException

createSession

protected javax.jms.Session createSession(javax.jms.Connection conn)
                                   throws javax.jms.JMSException

Overrides:

createSession in class org.springframework.jms.support.JmsAccessor

Throws:

javax.jms.JMSException

getConnection

protected javax.jms.Connection getConnection(org.springframework.jms.connection.JmsResourceHolder holder)

Overrides:

getConnection in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

getSession

protected javax.jms.Session getSession(org.springframework.jms.connection.JmsResourceHolder holder)

Overrides:

getSession in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

createSharedConnection

protected javax.jms.Connection createSharedConnection()
                                               throws javax.jms.JMSException

Overrides:

createSharedConnection in class org.springframework.jms.listener.AbstractJmsListeningContainer

Throws:

javax.jms.JMSException

receiveAndExecute

protected boolean receiveAndExecute(Object asyncMessageListenerInvoker,
                                    javax.jms.Session session,
                                    javax.jms.MessageConsumer consumer)
                             throws javax.jms.JMSException

Overrides:

receiveAndExecute in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

Throws:

javax.jms.JMSException

doReceiveAndExecute

protected boolean doReceiveAndExecute(Object invoker,
                                      javax.jms.Session session,
                                      javax.jms.MessageConsumer consumer,
                                      org.springframework.transaction.TransactionStatus txStatus)
                               throws javax.jms.JMSException

Overrides:

doReceiveAndExecute in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer

Throws:

javax.jms.JMSException

commitIfNecessary

protected void commitIfNecessary(javax.jms.Session session,
                                 @Nullable
                                 javax.jms.Message message)
                          throws javax.jms.JMSException

Overrides:

commitIfNecessary in class org.springframework.jms.listener.AbstractMessageListenerContainer

Throws:

javax.jms.JMSException

setCredentialFactory

public void setCredentialFactory(CredentialFactory credentialFactory)

getCredentialFactory

public CredentialFactory getCredentialFactory()