Class Amqp
java.lang.Object
org.springframework.integration.amqp.dsl.Amqp
Factory class for AMQP components.
- Since:
- 5.0
-
Method Summary
Modifier and TypeMethodDescriptionstatic AmqpAsyncOutboundGatewaySpecasyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate) Create an initial AmqpAsyncOutboundGatewaySpec.static AmqpMessageChannelSpec<?,?> Create an initial AmqpMessageChannelSpec.static AmqpMessageChannelSpec<?,?> channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpMessageChannelSpec.inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, String... queueNames) Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues) Create an initial AmqpInboundChannelAdapterSpec using aSimpleMessageListenerContainer.inboundAdapter(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer) Create an initialAmqpInboundGatewayDMLCSpecwith providedDirectMessageListenerContainer.inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) Create an initialAmqpInboundGatewaySMLCSpecwith providedSimpleMessageListenerContainer.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, String... queueNames) Create an initialAmqpInboundGatewaySpec.static AmqpInboundGatewaySMLCSpecinboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, 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.inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, String queue) Create an initial AmqpInboundPolledChannelAdapterSpec.inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, String queue) Create an initial AmqpInboundPolledChannelAdapterSpec.outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (adapter).static AmqpOutboundGatewaySpecoutboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate) Create an initial AmqpOutboundEndpointSpec (gateway).pollableChannel(String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPollableMessageChannelSpec.publishSubscribeChannel(String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPublishSubscribeMessageChannelSpec.publishSubscribeChannel(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, 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, 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, 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, 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, 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 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 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 String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) Create an initial AmqpPublishSubscribeMessageChannelSpec.- Parameters:
id- the id.connectionFactory- the connectionFactory.- Returns:
- the AmqpPublishSubscribeMessageChannelSpec.
-