Class AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>>

java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,P>
org.springframework.integration.dsl.MessageProducerSpec<S,AmqpInboundChannelAdapter>
org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec<S>
Type Parameters:
S - the target AmqpBaseInboundChannelAdapterSpec implementation type.
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<AmqpInboundChannelAdapter>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle
Direct Known Subclasses:
AmqpInboundChannelAdapterSpec

public class AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>> extends org.springframework.integration.dsl.MessageProducerSpec<S,AmqpInboundChannelAdapter>
The base MessageProducerSpec implementation for a AmqpInboundChannelAdapter.
Since:
5.0
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final DefaultAmqpHeaderMapper
     

    Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

    PARSER, target

    Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

    logger

    Fields inherited from interface org.springframework.beans.factory.FactoryBean

    OBJECT_TYPE_ATTRIBUTE

    Fields inherited from interface org.springframework.context.SmartLifecycle

    DEFAULT_PHASE
  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
     
  • Method Summary

    Modifier and Type
    Method
    Description
    Configure the adapter's AmqpHeaderMapper; defaults to DefaultAmqpHeaderMapper.
    Only applies if the default header mapper is used.
    messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
    Configure the adapter's MessageConverter; defaults to SimpleMessageConverter.
    messageRecoverer(org.springframework.amqp.rabbit.retry.MessageRecoverer messageRecoverer)
    Set a MessageRecoverer when using retry within the adapter.
    recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
    Set a RecoveryCallback when using retry within the adapter.
    retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
    Set a RetryTemplate to use for retrying a message delivery within the adapter.

    Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec

    autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, shouldTrack

    Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

    _this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

    Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

    afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Field Details

  • Constructor Details

  • Method Details

    • messageConverter

      public S messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
      Configure the adapter's MessageConverter; defaults to SimpleMessageConverter.
      Parameters:
      messageConverter - the messageConverter.
      Returns:
      the spec.
      See Also:
    • headerMapper

      public S headerMapper(AmqpHeaderMapper headerMapper)
      Configure the adapter's AmqpHeaderMapper; defaults to DefaultAmqpHeaderMapper.
      Parameters:
      headerMapper - the headerMapper.
      Returns:
      the spec.
    • mappedRequestHeaders

      public S mappedRequestHeaders(String... headers)
      Only applies if the default header mapper is used.
      Parameters:
      headers - the headers.
      Returns:
      the spec.
      See Also:
      • AbstractHeaderMapper.setRequestHeaderNames(String[])
    • retryTemplate

      public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
      Set a RetryTemplate to use for retrying a message delivery within the adapter.
      Parameters:
      retryTemplate - the template.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
    • recoveryCallback

      public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
      Set a RecoveryCallback when using retry within the adapter.
      Parameters:
      recoveryCallback - the callback.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
    • messageRecoverer

      public S messageRecoverer(org.springframework.amqp.rabbit.retry.MessageRecoverer messageRecoverer)
      Set a MessageRecoverer when using retry within the adapter.
      Parameters:
      messageRecoverer - the callback.
      Returns:
      the spec.
      Since:
      5.5
      See Also: