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 <S extends AmqpMessageChannelSpec<S>> |
channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
Create an initial AmqpMessageChannelSpec.
|
static <S extends 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>> |
pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
Create an initial AmqpPollableMessageChannelSpec.
|
static <S extends 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.
|
public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.queueNames - the queueNames.public static AmqpInboundGatewaySpec 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 AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
AmqpInboundGatewaySpec.connectionFactory - the connectionFactory.queues - the queues.public static AmqpInboundGatewaySpec 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 AmqpBaseInboundGatewaySpec<?> inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
AmqpBaseInboundGatewaySpec
with provided SimpleMessageListenerContainer.
Note: only endpoint options are available from spec.
The listenerContainer options should be specified
on the provided SimpleMessageListenerContainer.listenerContainer - the listenerContainerpublic static AmqpBaseInboundGatewaySpec<?> inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer, org.springframework.amqp.core.AmqpTemplate amqpTemplate)
AmqpBaseInboundGatewaySpec
with provided SimpleMessageListenerContainer.
Note: only endpoint options are available from spec.
The listenerContainer options should be specified
on the provided SimpleMessageListenerContainer.listenerContainer - the listenerContaineramqpTemplate - the AmqpTemplate to use.public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
connectionFactory - the connectionFactory.queueNames - the queueNames.public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
connectionFactory - the connectionFactory.queues - the queues.public static AmqpBaseInboundChannelAdapterSpec<?> inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
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 <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
S - the spec type.connectionFactory - the connectionFactory.public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
S - the spec type.id - the id.connectionFactory - the connectionFactory.public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
S - the spec type.connectionFactory - the connectionFactory.public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
S - the spec type.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.