org.springframework.integration.amqp.dsl

Class Amqp

java.lang.Object

org.springframework.integration.amqp.dsl.Amqp

public final class Amqp
extends Object

Factory class for AMQP components.

Since:

5.0

Author:

Artem Bilan

Method Summary

Modifier and Type	Method and Description
static AmqpAsyncOutboundGatewaySpec	asyncOutboundGateway(AsyncRabbitTemplate asyncRabbitTemplate) Create an initial AmqpAsyncOutboundGatewaySpec.
static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S>	channel(ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S>	channel(String id, ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static AmqpInboundChannelAdapterSpec	inboundAdapter(ConnectionFactory connectionFactory, Queue... queues) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpInboundChannelAdapterSpec	inboundAdapter(ConnectionFactory connectionFactory, String... queueNames) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpBaseInboundChannelAdapterSpec<?>	inboundAdapter(SimpleMessageListenerContainer listenerContainer) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpInboundGatewaySpec	inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(ConnectionFactory connectionFactory, Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(ConnectionFactory connectionFactory, String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpBaseInboundGatewaySpec<?>	inboundGateway(SimpleMessageListenerContainer listenerContainer) Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer.
static AmqpBaseInboundGatewaySpec<?>	inboundGateway(SimpleMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer.
static AmqpOutboundEndpointSpec	outboundAdapter(AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (adapter).
static AmqpOutboundEndpointSpec	outboundGateway(AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (gateway).
static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S>	pollableChannel(ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.
static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S>	pollableChannel(String id, ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.
static AmqpPublishSubscribeMessageChannelSpec	publishSubscribeChannel(ConnectionFactory connectionFactory) Create an initial AmqpPublishSubscribeMessageChannelSpec.
static AmqpPublishSubscribeMessageChannelSpec	publishSubscribeChannel(String id, ConnectionFactory connectionFactory) Create an initial AmqpPublishSubscribeMessageChannelSpec.

Methods inherited from class java.lang.Object

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

Method Detail

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(ConnectionFactory connectionFactory,
                                                    String... queueNames)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(ConnectionFactory connectionFactory,
                                                    AmqpTemplate amqpTemplate,
                                                    String... queueNames)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

amqpTemplate - the AmqpTemplate to use.

queueNames - the queueNames.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(ConnectionFactory connectionFactory,
                                                    Queue... queues)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(ConnectionFactory connectionFactory,
                                                    AmqpTemplate amqpTemplate,
                                                    Queue... queues)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

amqpTemplate - the AmqpTemplate to use.

queues - the queues.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpBaseInboundGatewaySpec<?> inboundGateway(SimpleMessageListenerContainer listenerContainer)

Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided SimpleMessageListenerContainer.

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpBaseInboundGatewaySpec.

inboundGateway

public static AmqpBaseInboundGatewaySpec<?> inboundGateway(SimpleMessageListenerContainer listenerContainer,
                                                           AmqpTemplate amqpTemplate)

Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided SimpleMessageListenerContainer.

Parameters:

listenerContainer - the listenerContainer

amqpTemplate - the AmqpTemplate to use.

Returns:

the AmqpBaseInboundGatewaySpec.

inboundAdapter

public static AmqpInboundChannelAdapterSpec inboundAdapter(ConnectionFactory connectionFactory,
                                                           String... queueNames)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

public static AmqpInboundChannelAdapterSpec inboundAdapter(ConnectionFactory connectionFactory,
                                                           Queue... queues)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

public static AmqpBaseInboundChannelAdapterSpec<?> inboundAdapter(SimpleMessageListenerContainer listenerContainer)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundChannelAdapterSpec.

outboundAdapter

public static AmqpOutboundEndpointSpec outboundAdapter(AmqpTemplate amqpTemplate)

Create an initial AmqpOutboundEndpointSpec (adapter).

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpOutboundEndpointSpec.

outboundGateway

public static AmqpOutboundEndpointSpec outboundGateway(AmqpTemplate amqpTemplate)

Create an initial AmqpOutboundEndpointSpec (gateway).

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpOutboundEndpointSpec.

asyncOutboundGateway

public static AmqpAsyncOutboundGatewaySpec asyncOutboundGateway(AsyncRabbitTemplate asyncRabbitTemplate)

Create an initial AmqpAsyncOutboundGatewaySpec.

Parameters:

asyncRabbitTemplate - the AsyncRabbitTemplate.

Returns:

the AmqpOutboundEndpointSpec.

pollableChannel

public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(ConnectionFactory connectionFactory)

Create an initial AmqpPollableMessageChannelSpec.

Type Parameters:

S - the spec type.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpPollableMessageChannelSpec.

pollableChannel

public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(String id,
                                                                                                              ConnectionFactory connectionFactory)

Create an initial AmqpPollableMessageChannelSpec.

Type Parameters:

S - the spec type.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpPollableMessageChannelSpec.

channel

public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(ConnectionFactory connectionFactory)

Create an initial AmqpMessageChannelSpec.

Type Parameters:

S - the spec type.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpMessageChannelSpec.

channel

public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(String id,
                                                                                      ConnectionFactory connectionFactory)

Create an initial AmqpMessageChannelSpec.

Type Parameters:

S - the spec type.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpMessageChannelSpec.

publishSubscribeChannel

public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(ConnectionFactory connectionFactory)

Create an initial AmqpPublishSubscribeMessageChannelSpec.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpPublishSubscribeMessageChannelSpec.

publishSubscribeChannel

public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(String id,
                                                                             ConnectionFactory connectionFactory)

Create an initial AmqpPublishSubscribeMessageChannelSpec.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpPublishSubscribeMessageChannelSpec.