Class Amqp
java.lang.Object
org.springframework.integration.amqp.dsl.Amqp
public final class Amqp
extends java.lang.Object
Factory class for AMQP components.
- Since:
- 5.0
-
Method Summary
Modifier and Type Method Description static AmqpAsyncOutboundGatewaySpecasyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate)Create an initial AmqpAsyncOutboundGatewaySpec.static AmqpMessageChannelSpec<?,?>channel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpMessageChannelSpec.static AmqpMessageChannelSpec<?,?>channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpMessageChannelSpec.static AmqpInboundChannelAdapterSMLCSpecinboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.static AmqpInboundChannelAdapterSMLCSpecinboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.static AmqpInboundChannelAdapterDMLCSpecinboundAdapter(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewayDMLCSpecwith providedDirectMessageListenerContainer.static AmqpInboundChannelAdapterSMLCSpecinboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)Create an initialAmqpInboundGatewaySpec.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, java.lang.String... queueNames)Create an initialAmqpInboundGatewaySpec.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, org.springframework.amqp.core.Queue... queues)Create an initialAmqpInboundGatewaySpec.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)Create an initialAmqpInboundGatewaySpec.static AmqpInboundGatewayDMLCSpecinboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)Create an initialDirectMessageListenerContainerSpecwith providedDirectMessageListenerContainer.static AmqpInboundGatewayDMLCSpecinboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initialAmqpInboundGatewayDMLCSpecwith providedDirectMessageListenerContainer.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer.static AmqpInboundPolledChannelAdapterSpecinboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String queue)Create an initial AmqpInboundPolledChannelAdapterSpecstatic AmqpInboundPolledChannelAdapterSpecinboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, java.lang.String queue)Create an initial AmqpInboundPolledChannelAdapterSpecstatic AmqpOutboundChannelAdapterSpecoutboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initial AmqpOutboundEndpointSpec (adapter).static AmqpOutboundGatewaySpecoutboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initial AmqpOutboundEndpointSpec (gateway).static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel>pollableChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPollableMessageChannelSpec.static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel>pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPollableMessageChannelSpec.static AmqpPublishSubscribeMessageChannelSpecpublishSubscribeChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPublishSubscribeMessageChannelSpec.static AmqpPublishSubscribeMessageChannelSpecpublishSubscribeChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPublishSubscribeMessageChannelSpec.
-
Method Details
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)Create an initialAmqpInboundGatewaySpec.- Parameters:
connectionFactory- the connectionFactory.queueNames- the queueNames.- Returns:
- the AmqpInboundGatewaySpec.
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, java.lang.String... queueNames)Create an initialAmqpInboundGatewaySpec.- Parameters:
connectionFactory- the connectionFactory.amqpTemplate- theAmqpTemplateto use.queueNames- the queueNames.- Returns:
- the AmqpInboundGatewaySpec.
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)Create an initialAmqpInboundGatewaySpec.- Parameters:
connectionFactory- the connectionFactory.queues- the queues.- Returns:
- the AmqpInboundGatewaySpec.
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, org.springframework.amqp.core.Queue... queues)Create an initialAmqpInboundGatewaySpec.- Parameters:
connectionFactory- the connectionFactory.amqpTemplate- theAmqpTemplateto use.queues- the queues.- Returns:
- the AmqpInboundGatewaySpec.
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedSimpleMessageListenerContainerusingAmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContainer- Returns:
- the AmqpInboundGatewaySMLCSpec.
-
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedSimpleMessageListenerContainerusingAmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContaineramqpTemplate- theAmqpTemplateto use.- Returns:
- the AmqpInboundGatewaySMLCSpec.
-
inboundGateway
public static AmqpInboundGatewayDMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)Create an initialDirectMessageListenerContainerSpecwith providedDirectMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedDirectMessageListenerContainerusingAmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContainer- Returns:
- the AmqpInboundGatewayDMLCSpec.
-
inboundGateway
public static AmqpInboundGatewayDMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initialAmqpInboundGatewayDMLCSpecwith providedDirectMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedDirectMessageListenerContainerusingAmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContaineramqpTemplate- theAmqpTemplateto use.- Returns:
- the AmqpInboundGatewayDMLCSpec.
-
inboundPolledAdapter
public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.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(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, java.lang.String queue)Create an initial AmqpInboundPolledChannelAdapterSpec- Parameters:
connectionFactory- the connectionFactory.ackCallbackFactory- the ackCallbackFactoryqueue- the queue.- Returns:
- the AmqpInboundPolledChannelAdapterSpec.
- Since:
- 5.0.1
-
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.- Parameters:
connectionFactory- the connectionFactory.queueNames- the queueNames.- Returns:
- the AmqpInboundChannelAdapterSpec.
-
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.- Parameters:
connectionFactory- the connectionFactory.queues- the queues.- Returns:
- the AmqpInboundChannelAdapterSpec.
-
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedSimpleMessageListenerContainerusingAmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContainer- Returns:
- the AmqpInboundGatewaySMLCSpec.
-
inboundAdapter
public static AmqpInboundChannelAdapterDMLCSpec inboundAdapter(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)Create an initialAmqpInboundGatewayDMLCSpecwith providedDirectMessageListenerContainer. Note: only endpoint options are available from spec. ThelistenerContaineroptions should be specified on the providedDirectMessageListenerContainerusingAmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer).- Parameters:
listenerContainer- the listenerContainer- Returns:
- the AmqpInboundGatewaySMLCSpec.
-
outboundAdapter
public static AmqpOutboundChannelAdapterSpec outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)Create an initial AmqpOutboundEndpointSpec (adapter).- Parameters:
amqpTemplate- the amqpTemplate.- Returns:
- the AmqpOutboundEndpointSpec.
-
outboundGateway
public static AmqpOutboundGatewaySpec 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- theAsyncRabbitTemplate.- Returns:
- the AmqpOutboundEndpointSpec.
-
pollableChannel
public static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel> pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPollableMessageChannelSpec.- Parameters:
connectionFactory- the connectionFactory.- Returns:
- the AmqpPollableMessageChannelSpec.
-
pollableChannel
public static AmqpPollableMessageChannelSpec<?,PollableAmqpChannel> pollableChannel(@Nullable java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpPollableMessageChannelSpec.- Parameters:
id- the id.connectionFactory- the connectionFactory.- Returns:
- the AmqpPollableMessageChannelSpec.
-
channel
public static AmqpMessageChannelSpec<?,?> channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpMessageChannelSpec.- Parameters:
connectionFactory- the connectionFactory.- Returns:
- the AmqpMessageChannelSpec.
-
channel
public static AmqpMessageChannelSpec<?,?> channel(@Nullable java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)Create an initial AmqpMessageChannelSpec.- 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(@Nullable 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.
-