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>
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.
IListenerConnector.CacheMode
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 |
log
THREAD_CONTEXT_SESSION_KEY
Constructor and Description |
---|
SpringJmsConnector() |
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.
|
configureEndpointConnection
public static final int DEFAULT_CACHE_LEVEL_TRANSACTED
public static final int DEFAULT_CACHE_LEVEL_NON_TRANSACTED
public static final int IDLE_TASK_EXECUTION_LIMIT
protected org.springframework.jms.listener.DefaultMessageListenerContainer createMessageListenerContainer() throws ConfigurationException
ConfigurationException
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
configureEndpointConnection
in interface IListenerConnector<javax.jms.Message>
ConfigurationException
public void start() throws ListenerException
IListenerConnector
start
in interface IListenerConnector<javax.jms.Message>
ListenerException
public void stop() throws ListenerException
IListenerConnector
stop
in interface IListenerConnector<javax.jms.Message>
ListenerException
public void onMessage(javax.jms.Message message, javax.jms.Session session) throws javax.jms.JMSException
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener<javax.jms.Message>
javax.jms.JMSException
public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
public boolean isThreadCountReadable()
isThreadCountReadable
in interface IThreadCountControllable
public boolean isThreadCountControllable()
isThreadCountControllable
in interface IThreadCountControllable
public int getCurrentThreadCount()
getCurrentThreadCount
in interface IThreadCountControllable
public int getMaxThreadCount()
getMaxThreadCount
in interface IThreadCountControllable
public void increaseThreadCount()
increaseThreadCount
in interface IThreadCountControllable
public void decreaseThreadCount()
decreaseThreadCount
in interface IThreadCountControllable
public String getLogPrefix()
Copyright © 2023 Frank!Framework. All rights reserved.