public abstract class Amqp
extends java.lang.Object
Constructor and Description |
---|
Amqp() |
Modifier and Type | Method and Description |
---|---|
static <S extends AmqpMessageChannelSpec<S>> |
channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static <S extends AmqpMessageChannelSpec<S>> |
channel(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static AmqpInboundChannelAdapterSpec |
inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.amqp.core.Queue... queues) |
static AmqpInboundChannelAdapterSpec |
inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String... queueNames) |
static MessageProducerSpec<AmqpInboundChannelAdapterSpec,org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter> |
inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) |
static AmqpInboundGatewaySpec |
inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
org.springframework.amqp.core.Queue... queues) |
static AmqpInboundGatewaySpec |
inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String... queueNames) |
static MessagingGatewaySpec<AmqpInboundGatewaySpec,org.springframework.integration.amqp.inbound.AmqpInboundGateway> |
inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer) |
static AmqpOutboundEndpointSpec |
outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
static AmqpOutboundEndpointSpec |
outboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate) |
static <S extends AmqpPollableMessageChannelSpec<S>> |
pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static <S extends AmqpPollableMessageChannelSpec<S>> |
pollableChannel(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static AmqpPublishSubscribeMessageChannelSpec |
publishSubscribeChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
static AmqpPublishSubscribeMessageChannelSpec |
publishSubscribeChannel(java.lang.String id,
org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
public static AmqpInboundGatewaySpec inboundGateway(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
public static MessagingGatewaySpec<AmqpInboundGatewaySpec,org.springframework.integration.amqp.inbound.AmqpInboundGateway> inboundGateway(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String... queueNames)
public static AmqpInboundChannelAdapterSpec inboundAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.core.Queue... queues)
public static MessageProducerSpec<AmqpInboundChannelAdapterSpec,org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter> inboundAdapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer listenerContainer)
public static AmqpOutboundEndpointSpec outboundAdapter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public static AmqpOutboundEndpointSpec outboundGateway(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static <S extends AmqpPollableMessageChannelSpec<S>> AmqpPollableMessageChannelSpec<S> pollableChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static <S extends AmqpMessageChannelSpec<S>> AmqpMessageChannelSpec<S> channel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(java.lang.String id, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)