Package org.springframework.integration.amqp.dsl

Class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,​E>,​E extends AbstractAmqpOutboundEndpoint>

java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,​H>
org.springframework.integration.dsl.MessageHandlerSpec<S,​E>
org.springframework.integration.amqp.dsl.AmqpBaseOutboundEndpointSpec<S,​E>
Type Parameters:
S - the target AmqpBaseOutboundEndpointSpec implementation type.
E - the target AbstractAmqpOutboundEndpoint implementation type.
All Implemented Interfaces:
Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<E>, InitializingBean, Lifecycle, Phased, SmartLifecycle
Direct Known Subclasses:
AmqpAsyncOutboundGatewaySpec, AmqpOutboundEndpointSpec
public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,​E>,​E extends AbstractAmqpOutboundEndpoint>
extends MessageHandlerSpec<S,​E>
The base MessageHandlerSpec for AbstractAmqpOutboundEndpoints.
Since:
5.0
Author:
Artem Bilan, Gary Russell

  • Field Details

  • Constructor Details

  • Method Details

    • headerMapper

      public S headerMapper​(AmqpHeaderMapper headerMapper)
      Set a custom AmqpHeaderMapper for mapping request and reply headers.
      Parameters:
      headerMapper - the AmqpHeaderMapper to use.
      Returns:
      the spec

    • defaultDeliveryMode

      public S defaultDeliveryMode​(MessageDeliveryMode defaultDeliveryMode)
      Set the default delivery mode.
      Parameters:
      defaultDeliveryMode - the delivery mode.
      Returns:
      the spec

    • routingKey

      public S routingKey​(String routingKey)
      Configure an AMQP routing key for sending messages.
      Parameters:
      routingKey - the routing key to use
      Returns:
      the spec

    • routingKeyExpression

      public S routingKeyExpression​(String routingKeyExpression)
      A SpEL expression to evaluate routing key at runtime.
      Parameters:
      routingKeyExpression - the expression to use.
      Returns:
      the spec

    • routingKeyFunction

      public S routingKeyFunction​(Function<Message<?>,​String> routingKeyFunction)
      A function to evaluate routing key at runtime.
      Parameters:
      routingKeyFunction - the Function to use.
      Returns:
      the spec

    • routingKeyExpression

      public S routingKeyExpression​(Expression routingKeyExpression)
      A SpEL expression to evaluate routing key at runtime.
      Parameters:
      routingKeyExpression - the expression to use.
      Returns:
      the spec

    • returnChannel

      public S returnChannel​(MessageChannel returnChannel)
      Set the channel to which returned messages are sent.
      Parameters:
      returnChannel - the channel.
      Returns:
      the spec

    • confirmAckChannel

      public S confirmAckChannel​(MessageChannel ackChannel)
      Set the channel to which acks are send (publisher confirms).
      Parameters:
      ackChannel - the channel.
      Returns:
      the spec

    • exchangeName

      public S exchangeName​(String exchangeName)
      Configure an AMQP exchange name for sending messages.
      Parameters:
      exchangeName - the exchange name for sending messages.
      Returns:
      the spec

    • exchangeNameExpression

      public S exchangeNameExpression​(String exchangeNameExpression)
      Configure a SpEL expression to evaluate an exchange name at runtime.
      Parameters:
      exchangeNameExpression - the expression to use.
      Returns:
      the spec

    • exchangeNameFunction

      public S exchangeNameFunction​(Function<Message<?>,​String> exchangeNameFunction)
      Configure a Function to evaluate an exchange name at runtime.
      Parameters:
      exchangeNameFunction - the function to use.
      Returns:
      the spec

    • exchangeNameExpression

      public S exchangeNameExpression​(Expression exchangeNameExpression)
      Configure a SpEL expression to evaluate an exchange name at runtime.
      Parameters:
      exchangeNameExpression - the expression to use.
      Returns:
      the spec

    • confirmNackChannel

      public S confirmNackChannel​(MessageChannel nackChannel)
      Set the channel to which nacks are send (publisher confirms).
      Parameters:
      nackChannel - the channel.
      Returns:
      the spec

    • confirmCorrelationExpression

      public S confirmCorrelationExpression​(String confirmCorrelationExpression)
      Set a SpEL expression to evaluate confirm correlation at runtime.
      Parameters:
      confirmCorrelationExpression - the expression to use.
      Returns:
      the spec

    • confirmCorrelationFunction

      public S confirmCorrelationFunction​(Function<Message<?>,​Object> confirmCorrelationFunction)
      Set a Function to evaluate confirm correlation at runtime.
      Parameters:
      confirmCorrelationFunction - the function to use.
      Returns:
      the spec

    • confirmCorrelationExpression

      public S confirmCorrelationExpression​(Expression confirmCorrelationExpression)
      Set a SpEL expression to evaluate confirm correlation at runtime.
      Parameters:
      confirmCorrelationExpression - the expression to use.
      Returns:
      the spec

    • mappedRequestHeaders

      public S mappedRequestHeaders​(String... headers)
      Provide the header names that should be mapped from a request to a MessageHeaders.
      Parameters:
      headers - The request header names.
      Returns:
      the spec

    • mappedReplyHeaders

      public S mappedReplyHeaders​(String... headers)
      Provide the header names that should be mapped to a response from a MessageHeaders.
      Parameters:
      headers - The reply header names.
      Returns:
      the spec

    • headersMappedLast

      public S headersMappedLast​(boolean headersLast)
      Determine whether the headers are mapped before the message is converted, or afterwards.
      Parameters:
      headersLast - true to map headers last.
      Returns:
      the spec.
      See Also:
      AbstractAmqpOutboundEndpoint.setHeadersMappedLast(boolean)

    • lazyConnect

      public S lazyConnect​(boolean lazyConnect)
      Set to false to attempt to connect during endpoint start.
      Parameters:
      lazyConnect - the lazyConnect to set.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      AbstractAmqpOutboundEndpoint.setLazyConnect(boolean)

    • delay

      public S delay​(int delay)
      Set the value to set in the x-delay header when using the RabbitMQ delayed message exchange plugin.
      Parameters:
      delay - the delay.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      AbstractAmqpOutboundEndpoint.setDelay(int)

    • delayFunction

      public S delayFunction​(Function<Message<?>,​Integer> delayFunction)
      Set the function to calculate the x-delay header when using the RabbitMQ delayed message exchange plugin.
      Parameters:
      delayFunction - the function to evaluate the value for the x-delay header.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      delayExpression(Expression)

    • delayExpression

      public S delayExpression​(Expression delayExpression)
      Set the SpEL expression to calculate the x-delay header when using the RabbitMQ delayed message exchange plugin.
      Parameters:
      delayExpression - the expression.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      AbstractAmqpOutboundEndpoint.setDelayExpression(Expression)

    • delayExpression

      public S delayExpression​(String delayExpression)
      Set the SpEL expression to calculate the x-delay header when using the RabbitMQ delayed message exchange plugin.
      Parameters:
      delayExpression - the expression.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      AbstractAmqpOutboundEndpoint.setDelayExpressionString(String)

    • errorMessageStrategy

      public S errorMessageStrategy​(ErrorMessageStrategy errorMessageStrategy)
      Set the error message strategy to use for returned (or negatively confirmed) messages.
      Parameters:
      errorMessageStrategy - the strategy.
      Returns:
      the spec.
      Since:
      5.0.2
      See Also:
      AbstractAmqpOutboundEndpoint.setErrorMessageStrategy(ErrorMessageStrategy)

    • confirmTimeout

      public S confirmTimeout​(long timeout)
      Set a timeout after which a nack will be synthesized if no publisher confirm has been received within that time. Missing confirms will be checked every 50% of this value so the synthesized nack will be sent between 1x and 1.5x this timeout.
      Parameters:
      timeout - the approximate timeout.
      Returns:
      the spec.
      Since:
      5.3