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

Author:

Artem Bilan

Method Summary

Modifier and Type	Method	Description
static AmqpClientInboundChannelAdapterSpec	inboundChannelAdapter(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)	Create an initial AmqpClientInboundChannelAdapterSpec.
static AmqpClientInboundGatewaySpec	inboundGateway(org.springframework.amqp.rabbitmq.client.AmqpConnectionFactory connectionFactory, String... queueNames)	Create an initial AmqpClientInboundGatewaySpec.
static AmqpClientMessageHandlerSpec	outboundAdapter(AsyncAmqpTemplate amqpTemplate)	Create an initial AmqpClientMessageHandlerSpec in an outbound channel adapter mode.
static AmqpClientMessageHandlerSpec	outboundGateway(AsyncAmqpTemplate amqpTemplate)	Create an initial AmqpClientMessageHandlerSpec in a gateway mode.

Methods inherited from class java.lang.Object

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

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(AsyncAmqpTemplate amqpTemplate)

Create an initial AmqpClientMessageHandlerSpec in an outbound channel adapter mode.

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpClientMessageHandlerSpec.

outboundGateway

public static AmqpClientMessageHandlerSpec outboundGateway(AsyncAmqpTemplate amqpTemplate)

Create an initial AmqpClientMessageHandlerSpec in a gateway mode.

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpClientMessageHandlerSpec.