org.springframework.integration.dsl.amqp

Class Amqp

java.lang.Object

org.springframework.integration.dsl.amqp.Amqp

public final class Amqp
extends java.lang.Object

Factory class for AMQP components.

Author:

Artem Bilan

Method Summary

Modifier and Type	Method and Description
static AmqpAsyncOutboundGatewaySpec	asyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate) Create an initial AmqpAsyncOutboundGatewaySpec.
static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S>	channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S>	channel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static AmqpInboundChannelAdapterSpec	inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpInboundChannelAdapterSpec	inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpBaseInboundChannelAdapterSpec<?>	inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) Create an initial AmqpInboundChannelAdapterSpec.
static AmqpInboundGatewaySpec	inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, org.springframework.amqp.core.Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, java.lang.String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySpec	inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpBaseInboundGatewaySpec<?>	inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer.
static AmqpBaseInboundGatewaySpec<?>	inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate) Create an initial AmqpBaseInboundGatewaySpec with provided SimpleMessageListenerContainer.
static AmqpOutboundEndpointSpec	outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (adapter).
static AmqpOutboundEndpointSpec	outboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (gateway).
static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S>	pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.
static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S>	pollableChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.
static AmqpPublishSubscribeMessageChannelSpec	publishSubscribeChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPublishSubscribeMessageChannelSpec.
static AmqpPublishSubscribeMessageChannelSpec	publishSubscribeChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.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(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                    java.lang.String... queueNames)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                    org.springframework.amqp.core.AmqpTemplate amqpTemplate,
                                                    java.lang.String... queueNames)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

amqpTemplate - the AmqpTemplate to use.

queueNames - the queueNames.

Returns:

the AmqpInboundGatewaySpec.

Since:

1.1.1

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                    org.springframework.amqp.core.Queue... queues)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                    org.springframework.amqp.core.AmqpTemplate amqpTemplate,
                                                    org.springframework.amqp.core.Queue... queues)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

amqpTemplate - the AmqpTemplate to use.

queues - the queues.

Returns:

the AmqpInboundGatewaySpec.

Since:

1.1.1

inboundGateway

public static AmqpBaseInboundGatewaySpec<?> inboundGateway(org.springframework.amqp.rabbit.listener.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(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer,
                                                           org.springframework.amqp.core.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.

Since:

1.1.1

inboundAdapter

public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                           java.lang.String... queueNames)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                           org.springframework.amqp.core.Queue... queues)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

public static AmqpBaseInboundChannelAdapterSpec<?> inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)

Create an initial AmqpInboundChannelAdapterSpec.

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundChannelAdapterSpec.

outboundAdapter

public static AmqpOutboundEndpointSpec outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Create an initial AmqpOutboundEndpointSpec (adapter).

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpOutboundEndpointSpec.

outboundGateway

public static AmqpOutboundEndpointSpec outboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate)

Create an initial AmqpOutboundEndpointSpec (gateway).

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpOutboundEndpointSpec.

asyncOutboundGateway

public static AmqpAsyncOutboundGatewaySpec asyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate)

Create an initial AmqpAsyncOutboundGatewaySpec.

Parameters:

asyncRabbitTemplate - the AsyncRabbitTemplate.

Returns:

the AmqpOutboundEndpointSpec.

Since:

1.2

pollableChannel

public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(org.springframework.amqp.rabbit.connection.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(java.lang.String id,
                                                                                                              org.springframework.amqp.rabbit.connection.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(org.springframework.amqp.rabbit.connection.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(java.lang.String id,
                                                                                      org.springframework.amqp.rabbit.connection.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(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

Create an initial AmqpPublishSubscribeMessageChannelSpec.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpPublishSubscribeMessageChannelSpec.

publishSubscribeChannel

public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(java.lang.String id,
                                                                             org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

Create an initial AmqpPublishSubscribeMessageChannelSpec.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpPublishSubscribeMessageChannelSpec.