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, Gary Russell, Artem Vozhdayenko

Method Summary

Modifier and Type	Method and Description
static AmqpAsyncOutboundGatewaySpec	asyncOutboundGateway(AsyncRabbitTemplate asyncRabbitTemplate) Create an initial AmqpAsyncOutboundGatewaySpec.
static AmqpMessageChannelSpec<?,?>	channel(ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static AmqpMessageChannelSpec<?,?>	channel(String id, ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.
static AmqpInboundChannelAdapterSMLCSpec	inboundAdapter(ConnectionFactory connectionFactory, Queue... queues) Create an initial AmqpInboundChannelAdapterSpec using a SimpleMessageListenerContainer.
static AmqpInboundChannelAdapterSMLCSpec	inboundAdapter(ConnectionFactory connectionFactory, String... queueNames) Create an initial AmqpInboundChannelAdapterSpec using a SimpleMessageListenerContainer.
static AmqpInboundChannelAdapterDMLCSpec	inboundAdapter(DirectMessageListenerContainer listenerContainer) Create an initial AmqpInboundGatewayDMLCSpec with provided DirectMessageListenerContainer.
static AmqpInboundChannelAdapterSMLCSpec	inboundAdapter(SimpleMessageListenerContainer listenerContainer) Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer.
static AmqpInboundGatewaySMLCSpec	inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySMLCSpec	inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySMLCSpec	inboundGateway(ConnectionFactory connectionFactory, Queue... queues) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewaySMLCSpec	inboundGateway(ConnectionFactory connectionFactory, String... queueNames) Create an initial AmqpInboundGatewaySpec.
static AmqpInboundGatewayDMLCSpec	inboundGateway(DirectMessageListenerContainer listenerContainer) Create an initial DirectMessageListenerContainerSpec with provided DirectMessageListenerContainer.
static AmqpInboundGatewayDMLCSpec	inboundGateway(DirectMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) Create an initial AmqpInboundGatewayDMLCSpec with provided DirectMessageListenerContainer.
static AmqpInboundGatewaySMLCSpec	inboundGateway(SimpleMessageListenerContainer listenerContainer) Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer.
static AmqpInboundGatewaySMLCSpec	inboundGateway(SimpleMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer.
static AmqpInboundPolledChannelAdapterSpec	inboundPolledAdapter(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, String queue) Create an initial AmqpInboundPolledChannelAdapterSpec
static AmqpInboundPolledChannelAdapterSpec	inboundPolledAdapter(ConnectionFactory connectionFactory, String queue) Create an initial AmqpInboundPolledChannelAdapterSpec
static AmqpOutboundChannelAdapterSpec	outboundAdapter(AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (adapter).
static AmqpOutboundGatewaySpec	outboundGateway(AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (gateway).
static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel>	pollableChannel(ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.
static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel>	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 AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory,
                                                        String... queueNames)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySMLCSpec 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 AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory,
                                                        Queue... queues)

Create an initial AmqpInboundGatewaySpec.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundGatewaySpec.

inboundGateway

public static AmqpInboundGatewaySMLCSpec 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 AmqpInboundGatewaySMLCSpec inboundGateway(SimpleMessageListenerContainer listenerContainer)

Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided SimpleMessageListenerContainer using AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundGatewaySMLCSpec.

inboundGateway

public static AmqpInboundGatewaySMLCSpec inboundGateway(SimpleMessageListenerContainer listenerContainer,
                                                        AmqpTemplate amqpTemplate)

Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided SimpleMessageListenerContainerusing AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

amqpTemplate - the AmqpTemplate to use.

Returns:

the AmqpInboundGatewaySMLCSpec.

inboundGateway

public static AmqpInboundGatewayDMLCSpec inboundGateway(DirectMessageListenerContainer listenerContainer)

Create an initial DirectMessageListenerContainerSpec with provided DirectMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided DirectMessageListenerContainer using AmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundGatewayDMLCSpec.

inboundGateway

public static AmqpInboundGatewayDMLCSpec inboundGateway(DirectMessageListenerContainer listenerContainer,
                                                        AmqpTemplate amqpTemplate)

Create an initial AmqpInboundGatewayDMLCSpec with provided DirectMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided DirectMessageListenerContainer using AmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

amqpTemplate - the AmqpTemplate to use.

Returns:

the AmqpInboundGatewayDMLCSpec.

inboundPolledAdapter

public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(ConnectionFactory connectionFactory,
                                                                       String queue)

Create an initial AmqpInboundPolledChannelAdapterSpec

Parameters:

connectionFactory - the connectionFactory.

queue - the queue.

Returns:

the AmqpInboundPolledChannelAdapterSpec.

Since:

5.0.1

inboundPolledAdapter

public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(ConnectionFactory connectionFactory,
                                                                       AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
                                                                       String queue)

Create an initial AmqpInboundPolledChannelAdapterSpec

Parameters:

connectionFactory - the connectionFactory.

ackCallbackFactory - the ackCallbackFactory

queue - the queue.

Returns:

the AmqpInboundPolledChannelAdapterSpec.

Since:

5.0.1

inboundAdapter

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

Create an initial AmqpInboundChannelAdapterSpec using a SimpleMessageListenerContainer.

Parameters:

connectionFactory - the connectionFactory.

queueNames - the queueNames.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

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

Create an initial AmqpInboundChannelAdapterSpec using a SimpleMessageListenerContainer.

Parameters:

connectionFactory - the connectionFactory.

queues - the queues.

Returns:

the AmqpInboundChannelAdapterSpec.

inboundAdapter

public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(SimpleMessageListenerContainer listenerContainer)

Create an initial AmqpInboundGatewaySMLCSpec with provided SimpleMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided SimpleMessageListenerContainer using AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundGatewaySMLCSpec.

inboundAdapter

public static AmqpInboundChannelAdapterDMLCSpec inboundAdapter(DirectMessageListenerContainer listenerContainer)

Create an initial AmqpInboundGatewayDMLCSpec with provided DirectMessageListenerContainer. Note: only endpoint options are available from spec. The listenerContainer options should be specified on the provided DirectMessageListenerContainer using AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).

Parameters:

listenerContainer - the listenerContainer

Returns:

the AmqpInboundGatewaySMLCSpec.

outboundAdapter

public static AmqpOutboundChannelAdapterSpec outboundAdapter(AmqpTemplate amqpTemplate)

Create an initial AmqpOutboundEndpointSpec (adapter).

Parameters:

amqpTemplate - the amqpTemplate.

Returns:

the AmqpOutboundEndpointSpec.

outboundGateway

public static AmqpOutboundGatewaySpec 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 AmqpPollableMessageChannelSpec<?,PollableAmqpChannel> pollableChannel(ConnectionFactory connectionFactory)

Create an initial AmqpPollableMessageChannelSpec.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpPollableMessageChannelSpec.

pollableChannel

public static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel> pollableChannel(@Nullable
                                                                                    String id,
                                                                                    ConnectionFactory connectionFactory)

Create an initial AmqpPollableMessageChannelSpec.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpPollableMessageChannelSpec.

channel

public static AmqpMessageChannelSpec<?,?> channel(ConnectionFactory connectionFactory)

Create an initial AmqpMessageChannelSpec.

Parameters:

connectionFactory - the connectionFactory.

Returns:

the AmqpMessageChannelSpec.

channel

public static AmqpMessageChannelSpec<?,?> channel(@Nullable
                                                  String id,
                                                  ConnectionFactory connectionFactory)

Create an initial AmqpMessageChannelSpec.

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(@Nullable
                                                                             String id,
                                                                             ConnectionFactory connectionFactory)

Create an initial AmqpPublishSubscribeMessageChannelSpec.

Parameters:

id - the id.

connectionFactory - the connectionFactory.

Returns:

the AmqpPublishSubscribeMessageChannelSpec.