Class AmqpClient

java.lang.Object
org.springframework.integration.amqp.dsl.AmqpClient
public final class AmqpClient extends Object
Factory class for AMQP 1.0 components.
Since:
7.0

  • Method Details

    • inboundGateway

      public static AmqpClientInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)
      Create an initial AmqpClientInboundGatewaySpec.
      Parameters:
      connectionFactory - the connectionFactory.
      queueNames - the queueNames.
      Returns:
      the AmqpClientInboundGatewaySpec.

    • inboundChannelAdapter

      public static AmqpClientInboundChannelAdapterSpec inboundChannelAdapter(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)
      Create an initial AmqpClientInboundChannelAdapterSpec.
      Parameters:
      connectionFactory - the connectionFactory.
      queueNames - the queues to consume from.
      Returns:
      the AmqpClientInboundChannelAdapterSpec.

    • outboundAdapter

      public static AmqpClientMessageHandlerSpec outboundAdapter(org.springframework.amqp.core.AsyncAmqpTemplate amqpTemplate)
      Create an initial AmqpClientMessageHandlerSpec in an outbound channel adapter mode.
      Parameters:
      amqpTemplate - the amqpTemplate.
      Returns:
      the AmqpClientMessageHandlerSpec.

    • outboundGateway

      public static AmqpClientMessageHandlerSpec outboundGateway(org.springframework.amqp.core.AsyncAmqpTemplate amqpTemplate)
      Create an initial AmqpClientMessageHandlerSpec in a gateway mode.
      Parameters:
      amqpTemplate - the amqpTemplate.
      Returns:
      the AmqpClientMessageHandlerSpec.