public class IbisMessageListenerContainer
extends org.springframework.jms.listener.DefaultMessageListenerContainer
Modifier and Type | Field and Description |
---|---|
protected org.apache.logging.log4j.Logger |
log |
CACHE_AUTO, CACHE_CONNECTION, CACHE_CONSUMER, CACHE_NONE, CACHE_SESSION, DEFAULT_RECOVERY_INTERVAL, DEFAULT_THREAD_NAME_PREFIX
DEFAULT_RECEIVE_TIMEOUT
lifecycleMonitor, sharedConnectionMonitor
Constructor and Description |
---|
IbisMessageListenerContainer() |
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) |
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
createListenerConsumer, getReceiveTimeout, getTransactionManager, isSessionLocallyTransacted, receiveMessage, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceived
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
afterPropertiesSet, destroy, doStart, doStop, getBeanName, getClientId, getPausedTaskCount, getPhase, getSharedConnection, isActive, isAutoStartup, isRunning, logRejectedTask, prepareSharedConnection, refreshSharedConnection, rescheduleTaskIfNecessary, resumePausedTasks, runningAllowed, setAutoStartup, setBeanName, setClientId, setPhase, shutdown, stop
getDestinationResolver, isPubSubDomain, receiveFromConsumer, resolveDestinationName, setDestinationResolver, setPubSubDomain
convertJmsAccessException, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, obtainConnectionFactory, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in class org.springframework.jms.support.JmsAccessor
javax.jms.JMSException
protected javax.jms.Session createSession(javax.jms.Connection conn) throws javax.jms.JMSException
createSession
in class org.springframework.jms.support.JmsAccessor
javax.jms.JMSException
protected javax.jms.Connection getConnection(org.springframework.jms.connection.JmsResourceHolder holder)
getConnection
in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
protected javax.jms.Session getSession(org.springframework.jms.connection.JmsResourceHolder holder)
getSession
in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
protected javax.jms.Connection createSharedConnection() throws javax.jms.JMSException
createSharedConnection
in class org.springframework.jms.listener.AbstractJmsListeningContainer
javax.jms.JMSException
protected boolean receiveAndExecute(Object asyncMessageListenerInvoker, javax.jms.Session session, javax.jms.MessageConsumer consumer) throws javax.jms.JMSException
receiveAndExecute
in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
javax.jms.JMSException
protected boolean doReceiveAndExecute(Object invoker, javax.jms.Session session, javax.jms.MessageConsumer consumer, org.springframework.transaction.TransactionStatus txStatus) throws javax.jms.JMSException
doReceiveAndExecute
in class org.springframework.jms.listener.AbstractPollingMessageListenerContainer
javax.jms.JMSException
protected void commitIfNecessary(javax.jms.Session session, @Nullable javax.jms.Message message) throws javax.jms.JMSException
commitIfNecessary
in class org.springframework.jms.listener.AbstractMessageListenerContainer
javax.jms.JMSException
public void setCredentialFactory(CredentialFactory credentialFactory)
public CredentialFactory getCredentialFactory()
Copyright © 2023 Frank!Framework. All rights reserved.