nl.nn.adapterframework.unmanaged

Class SpringJmsConnector

java.lang.Object

nl.nn.adapterframework.unmanaged.AbstractJmsConfigurator

nl.nn.adapterframework.unmanaged.SpringJmsConnector

All Implemented Interfaces:

javax.jms.ExceptionListener, IListenerConnector<javax.jms.Message>, IThreadCountControllable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>

public class SpringJmsConnector
extends AbstractJmsConfigurator
implements IListenerConnector<javax.jms.Message>, IThreadCountControllable, org.springframework.beans.factory.BeanFactoryAware, javax.jms.ExceptionListener, org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>

Configure a Spring JMS Container from a PushingJmsListener.

This implementation expects to receive an instance of org.springframework.jms.listener.DefaultMessageListenerContainer from the Spring BeanFactory. If another type of MessageListenerContainer is created by the BeanFactory, then another implementation of IListenerConnector should be provided as well.

This implementation works only with a PushingJmsListener, and not with other types PortConnectedListeners.

Since:

4.8

Author:

Tim van der Leeuw

Nested Class Summary

Nested classes/interfaces inherited from interface nl.nn.adapterframework.core.IListenerConnector

IListenerConnector.CacheMode

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CACHE_LEVEL_NON_TRANSACTED
static int	DEFAULT_CACHE_LEVEL_TRANSACTED
static int	IDLE_TASK_EXECUTION_LIMIT

Fields inherited from class nl.nn.adapterframework.unmanaged.AbstractJmsConfigurator

log

Fields inherited from interface nl.nn.adapterframework.core.IListenerConnector

THREAD_CONTEXT_SESSION_KEY

Constructor Summary

Constructors

Constructor and Description
SpringJmsConnector()

Method Summary

Modifier and Type	Method and Description
void	configureEndpointConnection(IPortConnectedListener<javax.jms.Message> jmsListener, javax.jms.ConnectionFactory connectionFactory, CredentialFactory credentialFactory, javax.jms.Destination destination, IbisExceptionListener exceptionListener, IListenerConnector.CacheMode cacheMode, int acknowledgeMode, boolean sessionTransacted, String messageSelector, long receiveTimeout, long pollGuardInterval)
protected org.springframework.jms.listener.DefaultMessageListenerContainer	createMessageListenerContainer()
void	decreaseThreadCount()
int	getCurrentThreadCount()
String	getLogPrefix()
int	getMaxThreadCount()
void	increaseThreadCount()
boolean	isThreadCountControllable()
boolean	isThreadCountReadable()
void	onException(javax.jms.JMSException e)
void	onMessage(javax.jms.Message message, javax.jms.Session session)
void	start() Start Listener-port to which the Listener is connected.
void	stop() Stop Listener-port to which the Listener is connected.

Methods inherited from class nl.nn.adapterframework.unmanaged.AbstractJmsConfigurator

configureEndpointConnection

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.BeanFactoryAware

setBeanFactory

Field Detail

DEFAULT_CACHE_LEVEL_TRANSACTED

public static final int DEFAULT_CACHE_LEVEL_TRANSACTED

See Also:

Constant Field Values

DEFAULT_CACHE_LEVEL_NON_TRANSACTED

public static final int DEFAULT_CACHE_LEVEL_NON_TRANSACTED

See Also:

Constant Field Values

IDLE_TASK_EXECUTION_LIMIT

public static final int IDLE_TASK_EXECUTION_LIMIT

See Also:

Constant Field Values

Constructor Detail

SpringJmsConnector

public SpringJmsConnector()

Method Detail

createMessageListenerContainer

protected org.springframework.jms.listener.DefaultMessageListenerContainer createMessageListenerContainer()
                                                                                                   throws ConfigurationException

Throws:

ConfigurationException

configureEndpointConnection

public void configureEndpointConnection(IPortConnectedListener<javax.jms.Message> jmsListener,
                                        javax.jms.ConnectionFactory connectionFactory,
                                        CredentialFactory credentialFactory,
                                        javax.jms.Destination destination,
                                        IbisExceptionListener exceptionListener,
                                        IListenerConnector.CacheMode cacheMode,
                                        int acknowledgeMode,
                                        boolean sessionTransacted,
                                        String messageSelector,
                                        long receiveTimeout,
                                        long pollGuardInterval)
                                 throws ConfigurationException

Specified by:

configureEndpointConnection in interface IListenerConnector<javax.jms.Message>

Throws:

ConfigurationException

start

public void start()
           throws ListenerException

Description copied from interface: IListenerConnector

Start Listener-port to which the Listener is connected.

Specified by:

start in interface IListenerConnector<javax.jms.Message>

Throws:

ListenerException

stop

public void stop()
          throws ListenerException

Description copied from interface: IListenerConnector

Stop Listener-port to which the Listener is connected.

Specified by:

stop in interface IListenerConnector<javax.jms.Message>

Throws:

ListenerException

onMessage

public void onMessage(javax.jms.Message message,
                      javax.jms.Session session)
               throws javax.jms.JMSException

Specified by:

onMessage in interface org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>

Throws:

javax.jms.JMSException

onException

public void onException(javax.jms.JMSException e)

Specified by:

onException in interface javax.jms.ExceptionListener

isThreadCountReadable

public boolean isThreadCountReadable()

Specified by:

isThreadCountReadable in interface IThreadCountControllable

isThreadCountControllable

public boolean isThreadCountControllable()

Specified by:

isThreadCountControllable in interface IThreadCountControllable

getCurrentThreadCount

public int getCurrentThreadCount()

Specified by:

getCurrentThreadCount in interface IThreadCountControllable

getMaxThreadCount

public int getMaxThreadCount()

Specified by:

getMaxThreadCount in interface IThreadCountControllable

increaseThreadCount

public void increaseThreadCount()

Specified by:

increaseThreadCount in interface IThreadCountControllable

decreaseThreadCount

public void decreaseThreadCount()

Specified by:

decreaseThreadCount in interface IThreadCountControllable

getLogPrefix

public String getLogPrefix()