Package com.boutouil.binder.jms.message.handler

Class JmsInboundChannelAdapter

  • All Implemented Interfaces:
    org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.context.OrderlyShutdownCapable, org.springframework.integration.core.MessageProducer, org.springframework.integration.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ManageableLifecycle, org.springframework.integration.support.management.ManageableSmartLifecycle, org.springframework.integration.support.management.TrackableComponent
    public class JmsInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.integration.context.OrderlyShutdownCapable

    • Field Summary

      • Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

        lifecycleCondition, lifecycleLock

      • Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

        EXPRESSION_PARSER, logger

      • Fields inherited from interface org.springframework.context.SmartLifecycle

        DEFAULT_PHASE

    • Constructor Summary

      Constructors 
      Constructor Description
      JmsInboundChannelAdapter​(org.springframework.jms.config.AbstractJmsListenerContainerFactory<org.springframework.jms.listener.DefaultMessageListenerContainer> listenerContainerFactory, JmsConsumerDestination jmsConsumerDestination, String group, org.springframework.jms.support.converter.MessageConverter messageConverter, org.springframework.messaging.support.HeaderMapper<javax.jms.Message> headerMapper)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int afterShutdown()  
      int beforeShutdown()  
      protected void doStart()  
      protected void doStop()  
      String getComponentType()  
      protected org.springframework.core.AttributeAccessor getErrorMessageAttributes​(org.springframework.messaging.Message<?> message)  
      protected void onInit()  
      void setBindSourceMessage​(boolean bindSourceMessage)  
      void setRecoveryCallback​(org.springframework.retry.RecoveryCallback<?> recoveryCallback)  
      void setRetryTemplate​(org.springframework.retry.support.RetryTemplate retryTemplate)  

      • Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

        afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

      • Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

        destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

      • Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

        afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

      • Methods inherited from interface org.springframework.integration.support.context.NamedComponent

        getBeanName, getComponentName

    • Constructor Detail

      • JmsInboundChannelAdapter

        public JmsInboundChannelAdapter​(org.springframework.jms.config.AbstractJmsListenerContainerFactory<org.springframework.jms.listener.DefaultMessageListenerContainer> listenerContainerFactory,
                                JmsConsumerDestination jmsConsumerDestination,
                                String group,
                                org.springframework.jms.support.converter.MessageConverter messageConverter,
                                org.springframework.messaging.support.HeaderMapper<javax.jms.Message> headerMapper)

    • Method Detail

      • setRetryTemplate

        public void setRetryTemplate​(org.springframework.retry.support.RetryTemplate retryTemplate)

      • setRecoveryCallback

        public void setRecoveryCallback​(org.springframework.retry.RecoveryCallback<?> recoveryCallback)

      • setBindSourceMessage

        public void setBindSourceMessage​(boolean bindSourceMessage)

      • getComponentType

        public String getComponentType()
        Specified by:
        getComponentType in interface org.springframework.integration.support.context.NamedComponent
        Overrides:
        getComponentType in class org.springframework.integration.context.IntegrationObjectSupport

      • onInit

        protected void onInit()
        Overrides:
        onInit in class org.springframework.integration.endpoint.MessageProducerSupport

      • doStart

        protected void doStart()
        Overrides:
        doStart in class org.springframework.integration.endpoint.MessageProducerSupport

      • doStop

        protected void doStop()
        Overrides:
        doStop in class org.springframework.integration.endpoint.MessageProducerSupport

      • beforeShutdown

        public int beforeShutdown()
        Specified by:
        beforeShutdown in interface org.springframework.integration.context.OrderlyShutdownCapable

      • afterShutdown

        public int afterShutdown()
        Specified by:
        afterShutdown in interface org.springframework.integration.context.OrderlyShutdownCapable

      • getErrorMessageAttributes

        protected org.springframework.core.AttributeAccessor getErrorMessageAttributes​(org.springframework.messaging.Message<?> message)
        Overrides:
        getErrorMessageAttributes in class org.springframework.integration.endpoint.MessageProducerSupport