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 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 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 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 SimpleMessageListenerContainer
using
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 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 <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.