Package com.boutouil.binder.jms

Class JmsMessageChannelBinder

java.lang.Object
org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,C,P>
org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>
com.boutouil.binder.jms.JmsMessageChannelBinder
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,JmsConsumerProperties,JmsProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware
public class JmsMessageChannelBinder extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>> implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,JmsConsumerProperties,JmsProducerProperties>

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

    org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure, org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources

  • Field Summary

    Fields inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

    provisioningProvider

    Fields inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    JmsMessageChannelBinder(org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>> provisioningProvider, JmsMessageHandlerFactory jmsMessageHandlerFactory, org.springframework.jms.config.DefaultJmsListenerContainerFactory jmsListenerContainerFactory, org.springframework.cloud.stream.config.ListenerContainerCustomizer<org.springframework.jms.listener.AbstractMessageListenerContainer> containerCustomizer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.springframework.integration.core.MessageProducer
    createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
     
    protected org.springframework.messaging.MessageHandler
    createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
     
    String
    getDefaultsPrefix()
     
    protected org.springframework.messaging.MessageHandler
    getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
     
    protected org.springframework.integration.support.ErrorMessageStrategy
    getErrorMessageStrategy()
     
    JmsConsumerProperties
    getExtendedConsumerProperties(String channelName)
     
    JmsProducerProperties
    getExtendedProducerProperties(String channelName)
     
    Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>
    getExtendedPropertiesEntryClass()
     
    protected void
    postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties)
     
    void
    setExtendedBindingProperties(JmsExtendedBindingProperties extendedBindingProperties)
     

    Methods inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

    afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandlerName, getErrorRecovererName, getMessageSourceCustomizer, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, onInit, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher, setConsumerEndpointCustomizer, setProducerMessageHandlerCustomizer, useNativeEncoding

    Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinder

    afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getEvaluationContext, groupedName, setApplicationContext

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.cloud.stream.binder.Binder

    bindConsumer, bindProducer

    Methods inherited from interface org.springframework.cloud.stream.binder.ExtendedBindingProperties

    getBindings

  • Constructor Details

    • JmsMessageChannelBinder

      public JmsMessageChannelBinder(org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>> provisioningProvider, JmsMessageHandlerFactory jmsMessageHandlerFactory, org.springframework.jms.config.DefaultJmsListenerContainerFactory jmsListenerContainerFactory, org.springframework.cloud.stream.config.ListenerContainerCustomizer<org.springframework.jms.listener.AbstractMessageListenerContainer> containerCustomizer)

  • Method Details

    • setExtendedBindingProperties

      public void setExtendedBindingProperties(JmsExtendedBindingProperties extendedBindingProperties)

    • getExtendedConsumerProperties

      public JmsConsumerProperties getExtendedConsumerProperties(String channelName)
      Specified by:
      getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

    • getExtendedProducerProperties

      public JmsProducerProperties getExtendedProducerProperties(String channelName)
      Specified by:
      getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

    • getDefaultsPrefix

      public String getDefaultsPrefix()
      Specified by:
      getDefaultsPrefix in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

    • getExtendedPropertiesEntryClass

      public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()
      Specified by:
      getExtendedPropertiesEntryClass in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

    • postProcessOutputChannel

      protected void postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties)
      Overrides:
      postProcessOutputChannel in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

    • createProducerMessageHandler

      protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
      Specified by:
      createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

    • createConsumerEndpoint

      protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
      Specified by:
      createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

    • getErrorMessageHandler

      protected org.springframework.messaging.MessageHandler getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
      Overrides:
      getErrorMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

    • getErrorMessageStrategy

      protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()
      Overrides:
      getErrorMessageStrategy in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>