Class SpringJmsConnector

java.lang.Object

org.frankframework.unmanaged.AbstractJmsConfigurator

org.frankframework.unmanaged.SpringJmsConnector

All Implemented Interfaces:

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

public class SpringJmsConnector
extends AbstractJmsConfigurator
implements IListenerConnector<jakarta.jms.Message>, IThreadCountControllable, org.springframework.beans.factory.BeanFactoryAware, jakarta.jms.ExceptionListener, org.springframework.jms.listener.SessionAwareMessageListener<jakarta.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 IListenerConnector

IListenerConnector.CacheMode

Field Summary

Fields

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

Fields inherited from class AbstractJmsConfigurator

log

Fields inherited from interface IListenerConnector

THREAD_CONTEXT_SESSION_KEY

Constructor Summary

Constructors

Constructor	Description
SpringJmsConnector()

Method Summary

Modifier and Type	Method	Description
void	configureEndpointConnection(IPortConnectedListener<jakarta.jms.Message> jmsListener, jakarta.jms.ConnectionFactory connectionFactory, CredentialFactory credentialFactory, jakarta.jms.Destination destination, IbisExceptionListener exceptionListener, IListenerConnector.CacheMode cacheMode, int acknowledgeMode, String messageSelector, long receiveTimeout, long pollGuardInterval)
void	decreaseThreadCount()
int	getCurrentThreadCount()
String	getLogPrefix()
int	getMaxThreadCount()
void	increaseThreadCount()
boolean	isThreadCountControllable()
boolean	isThreadCountReadable()
void	onException(jakarta.jms.JMSException e)
void	onMessage(jakarta.jms.Message message, @NonNull jakarta.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 AbstractJmsConfigurator

configureEndpointConnection

Methods inherited from class Object

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

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

setBeanFactory

Field Details

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 Details

SpringJmsConnector

public SpringJmsConnector()

Method Details

configureEndpointConnection

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

Specified by:

configureEndpointConnection in interface IListenerConnector<jakarta.jms.Message>

Throws:

ConfigurationException

start

public void start()

Description copied from interface: IListenerConnector

Start Listener-port to which the Listener is connected.

Specified by:

start in interface IListenerConnector<jakarta.jms.Message>

stop

public void stop()

Description copied from interface: IListenerConnector

Stop Listener-port to which the Listener is connected.

Specified by:

stop in interface IListenerConnector<jakarta.jms.Message>

onMessage

public void onMessage(jakarta.jms.Message message,
 @NonNull jakarta.jms.Session session)
               throws jakarta.jms.JMSException

Specified by:

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

Throws:

jakarta.jms.JMSException

onException

public void onException(jakarta.jms.JMSException e)

Specified by:

onException in interface jakarta.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()