org.springframework.data.jdbc.jms.listener.oracle
Class AdtMessageListenerContainer
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
org.springframework.data.jdbc.jms.listener.oracle.AdtMessageListenerContainer
- All Implemented Interfaces:
- BeanNameAware, DisposableBean, InitializingBean, Lifecycle, Phased, SmartLifecycle
public class AdtMessageListenerContainer
- extends DefaultMessageListenerContainer
MessageListenerContainer that handles ADT payloads by providing a custom implementation
of the ORADataFactory interface. This factory is required to integrate with
the AQ JMS API.
- Since:
- 1.0
|
Method Summary |
protected javax.jms.MessageConsumer |
createConsumer(javax.jms.Session session,
javax.jms.Destination destination)
|
protected void |
doShutdown()
|
| Methods inherited from class org.springframework.jms.listener.DefaultMessageListenerContainer |
createDefaultTaskExecutor, doInitialize, doRescheduleTask, establishSharedConnection, getActiveConsumerCount, getCacheLevel, getConcurrentConsumers, getIdleConsumerLimit, getIdleTaskExecutionLimit, getMaxConcurrentConsumers, getMaxMessagesPerTask, getScheduledConsumerCount, handleListenerSetupFailure, initialize, isRegisteredWithDestination, messageReceived, noMessageReceived, recoverAfterListenerSetupFailure, refreshConnectionUntilSuccessful, refreshDestination, scheduleNewInvokerIfAppropriate, setCacheLevel, setCacheLevelName, setConcurrency, setConcurrentConsumers, setIdleConsumerLimit, setIdleTaskExecutionLimit, setMaxConcurrentConsumers, setMaxMessagesPerTask, setRecoveryInterval, setTaskExecutor, sharedConnectionEnabled, sleepInbetweenRecoveryAttempts, start, startSharedConnection, stop, stopSharedConnection, validateConfiguration |
| Methods inherited from class org.springframework.jms.listener.AbstractPollingMessageListenerContainer |
createListenerConsumer, doReceiveAndExecute, getConnection, getSession, getTransactionManager, isPubSubNoLocal, isSessionLocallyTransacted, receiveAndExecute, receiveMessage, setPubSubNoLocal, setReceiveTimeout, setSessionTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, shouldCommitAfterNoMessageReceived |
| Methods inherited from class org.springframework.jms.listener.AbstractMessageListenerContainer |
checkMessageListener, commitIfNecessary, doExecuteListener, doInvokeListener, doInvokeListener, executeListener, getDefaultSubscriptionName, getDestination, getDestinationDescription, getDestinationName, getDurableSubscriptionName, getExceptionListener, getMessageListener, getMessageSelector, handleListenerException, invokeErrorHandler, invokeExceptionListener, invokeListener, isAcceptMessagesWhileStopping, isExposeListenerSession, isSubscriptionDurable, rollbackIfNecessary, rollbackOnExceptionIfNecessary, setAcceptMessagesWhileStopping, setDestination, setDestinationName, setDurableSubscriptionName, setErrorHandler, setExceptionListener, setExposeListenerSession, setMessageListener, setMessageSelector, setSubscriptionDurable |
| Methods inherited from class org.springframework.jms.listener.AbstractJmsListeningContainer |
afterPropertiesSet, createSharedConnection, 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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AdtMessageListenerContainer
public AdtMessageListenerContainer()
createConsumer
protected javax.jms.MessageConsumer createConsumer(javax.jms.Session session,
javax.jms.Destination destination)
throws javax.jms.JMSException
- Overrides:
createConsumer in class AbstractPollingMessageListenerContainer
- Throws:
javax.jms.JMSException
doShutdown
protected void doShutdown()
throws javax.jms.JMSException
- Overrides:
doShutdown in class DefaultMessageListenerContainer
- Throws:
javax.jms.JMSException