public final class Amqp
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static AmqpAsyncOutboundGatewaySpec |
asyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate)
Create an initial AmqpAsyncOutboundGatewaySpec.
|
static AmqpMessageChannelSpec<?> |
channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
Create an initial AmqpMessageChannelSpec.
|
static AmqpMessageChannelSpec<?> |
channel(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
Create an initial AmqpMessageChannelSpec.
|
static AmqpInboundChannelAdapterSMLCSpec |
inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.amqp.core.Queue... queues)
Create an initial AmqpInboundChannelAdapterSpec using a
SimpleMessageListenerContainer. |
static AmqpInboundChannelAdapterSMLCSpec |
inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String... queueNames)
Create an initial AmqpInboundChannelAdapterSpec using a
SimpleMessageListenerContainer. |
static AmqpInboundChannelAdapterDMLCSpec |
inboundAdapter(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
Create an initial
AmqpInboundGatewayDMLCSpec
with provided DirectMessageListenerContainer. |
static AmqpInboundChannelAdapterSMLCSpec |
inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
Create an initial
AmqpInboundGatewaySMLCSpec
with provided SimpleMessageListenerContainer. |
static AmqpInboundGatewaySMLCSpec |
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 AmqpInboundGatewaySMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.amqp.core.AmqpTemplate amqpTemplate,
java.lang.String... queueNames)
Create an initial
AmqpInboundGatewaySpec. |
static AmqpInboundGatewaySMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.amqp.core.Queue... queues)
Create an initial
AmqpInboundGatewaySpec. |
static AmqpInboundGatewaySMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String... queueNames)
Create an initial
AmqpInboundGatewaySpec. |
static AmqpInboundGatewayDMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
Create an initial
DirectMessageListenerContainerSpec
with provided DirectMessageListenerContainer. |
static AmqpInboundGatewayDMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
Create an initial
AmqpInboundGatewayDMLCSpec
with provided DirectMessageListenerContainer. |
static AmqpInboundGatewaySMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
Create an initial
AmqpInboundGatewaySMLCSpec
with provided SimpleMessageListenerContainer. |
static AmqpInboundGatewaySMLCSpec |
inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer,
org.springframework.amqp.core.AmqpTemplate amqpTemplate)
Create an initial
AmqpInboundGatewaySMLCSpec
with provided SimpleMessageListenerContainer. |
static AmqpInboundPolledChannelAdapterSpec |
inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
java.lang.String queue)
Create an initial AmqpInboundPolledChannelAdapterSpec
|
static AmqpInboundPolledChannelAdapterSpec |
inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String queue)
Create an initial AmqpInboundPolledChannelAdapterSpec
|
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 AmqpPollableMessageChannelSpec<?> |
pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
Create an initial AmqpPollableMessageChannelSpec.
|
static AmqpPollableMessageChannelSpec<?> |
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.
|
public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.queueNames - the queueNames.public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, java.lang.String... queueNames)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.amqpTemplate - the AmqpTemplate to use.queueNames - the queueNames.public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.queues - the queues.public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.AmqpTemplate amqpTemplate, org.springframework.amqp.core.Queue... queues)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.amqpTemplate - the AmqpTemplate to use.queues - the queues.public static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
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).listenerContainer - the listenerContainerpublic static AmqpInboundGatewaySMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)
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).listenerContainer - the listenerContaineramqpTemplate - the AmqpTemplate to use.public static AmqpInboundGatewayDMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
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).listenerContainer - the listenerContainerpublic static AmqpInboundGatewayDMLCSpec inboundGateway(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)
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).listenerContainer - the listenerContaineramqpTemplate - the AmqpTemplate to use.public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String queue)
connectionFactory - the connectionFactory.queue - the queue.public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, java.lang.String queue)
connectionFactory - the connectionFactory.ackCallbackFactory - the ackCallbackFactoryqueue - the queue.public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
SimpleMessageListenerContainer.connectionFactory - the connectionFactory.queueNames - the queueNames.public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
SimpleMessageListenerContainer.connectionFactory - the connectionFactory.queues - the queues.public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
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).listenerContainer - the listenerContainerpublic static AmqpInboundChannelAdapterDMLCSpec inboundAdapter(org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer listenerContainer)
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).listenerContainer - the listenerContainerpublic static AmqpOutboundEndpointSpec outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
amqpTemplate - the amqpTemplate.public static AmqpOutboundEndpointSpec outboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
amqpTemplate - the amqpTemplate.public static AmqpAsyncOutboundGatewaySpec asyncOutboundGateway(org.springframework.amqp.rabbit.AsyncRabbitTemplate asyncRabbitTemplate)
asyncRabbitTemplate - the AsyncRabbitTemplate.public static AmqpPollableMessageChannelSpec<?> pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
connectionFactory - the connectionFactory.public static AmqpPollableMessageChannelSpec<?> pollableChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
id - the id.connectionFactory - the connectionFactory.public static AmqpMessageChannelSpec<?> channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
connectionFactory - the connectionFactory.public static AmqpMessageChannelSpec<?> channel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
id - the id.connectionFactory - the connectionFactory.public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
connectionFactory - the connectionFactory.public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
id - the id.connectionFactory - the connectionFactory.