クラス Amqp
java.lang.ObjectSE
org.springframework.integration.amqp.dsl.Amqp
AMQP コンポーネントのファクトリクラス。
- 導入:
- 5.0
- 作成者:
- Artem Bilan, Gary Russell, Artem Vozhdayenko
メソッドのサマリー
修飾子と型メソッド説明static AmqpAsyncOutboundGatewaySpec
asyncOutboundGateway
(AsyncRabbitTemplate asyncRabbitTemplate) 初期 AmqpAsyncOutboundGatewaySpec を作成します。static AmqpMessageChannelSpec
<?, ?> channel
(StringSE id, ConnectionFactory connectionFactory) 初期 AmqpMessageChannelSpec を作成します。static AmqpMessageChannelSpec
<?, ?> channel
(ConnectionFactory connectionFactory) 初期 AmqpMessageChannelSpec を作成します。inboundAdapter
(ConnectionFactory connectionFactory, StringSE... queueNames) SimpleMessageListenerContainer
を使用して初期 AmqpInboundChannelAdapterSpec を作成します。inboundAdapter
(ConnectionFactory connectionFactory, Queue... queues) SimpleMessageListenerContainer
を使用して初期 AmqpInboundChannelAdapterSpec を作成します。inboundAdapter
(DirectMessageListenerContainer listenerContainer) 提供されたDirectMessageListenerContainer
で初期AmqpInboundGatewayDMLCSpec
を作成します。inboundAdapter
(SimpleMessageListenerContainer listenerContainer) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(ConnectionFactory connectionFactory, StringSE... queueNames) 初期AmqpInboundGatewaySpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, StringSE... queueNames) 初期AmqpInboundGatewaySpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, Queue... queues) 初期AmqpInboundGatewaySpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(ConnectionFactory connectionFactory, Queue... queues) 初期AmqpInboundGatewaySpec
を作成します。static AmqpInboundGatewayDMLCSpec
inboundGateway
(DirectMessageListenerContainer listenerContainer) 提供されたDirectMessageListenerContainer
で初期DirectMessageListenerContainerSpec
を作成します。static AmqpInboundGatewayDMLCSpec
inboundGateway
(DirectMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) 提供されたDirectMessageListenerContainer
で初期AmqpInboundGatewayDMLCSpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(SimpleMessageListenerContainer listenerContainer) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。static AmqpInboundGatewaySMLCSpec
inboundGateway
(SimpleMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。inboundPolledAdapter
(ConnectionFactory connectionFactory, StringSE queue) 初期 AmqpInboundPolledChannelAdapterSpec を作成します。inboundPolledAdapter
(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, StringSE queue) 初期 AmqpInboundPolledChannelAdapterSpec を作成します。outboundAdapter
(AmqpTemplate amqpTemplate) 初期 AmqpOutboundEndpointSpec(アダプター)を作成します。static AmqpOutboundGatewaySpec
outboundGateway
(AmqpTemplate amqpTemplate) 初期 AmqpOutboundEndpointSpec(ゲートウェイ)を作成します。pollableChannel
(StringSE id, ConnectionFactory connectionFactory) 初期 AmqpPollableMessageChannelSpec を作成します。pollableChannel
(ConnectionFactory connectionFactory) 初期 AmqpPollableMessageChannelSpec を作成します。publishSubscribeChannel
(StringSE id, ConnectionFactory connectionFactory) 初期 AmqpPublishSubscribeMessageChannelSpec を作成します。publishSubscribeChannel
(ConnectionFactory connectionFactory) 初期 AmqpPublishSubscribeMessageChannelSpec を作成します。
メソッドの詳細
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory, StringSE... queueNames) 初期AmqpInboundGatewaySpec
を作成します。- パラメーター:
connectionFactory
- connectionFactory。queueNames
- queueNames。- 戻り値:
- AmqpInboundGatewaySpec。
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, StringSE... queueNames) 初期AmqpInboundGatewaySpec
を作成します。- パラメーター:
connectionFactory
- connectionFactory。amqpTemplate
- 使用するAmqpTemplate
。queueNames
- queueNames。- 戻り値:
- AmqpInboundGatewaySpec。
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory, Queue... queues) 初期AmqpInboundGatewaySpec
を作成します。- パラメーター:
connectionFactory
- connectionFactory。queues
- キュー。- 戻り値:
- AmqpInboundGatewaySpec。
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, Queue... queues) 初期AmqpInboundGatewaySpec
を作成します。- パラメーター:
connectionFactory
- connectionFactory。amqpTemplate
- 使用するAmqpTemplate
。queues
- キュー。- 戻り値:
- AmqpInboundGatewaySpec。
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(SimpleMessageListenerContainer listenerContainer) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているSimpleMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContainer- 戻り値:
- AmqpInboundGatewaySMLCSpec。
inboundGateway
public static AmqpInboundGatewaySMLCSpec inboundGateway(SimpleMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているSimpleMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContaineramqpTemplate
- 使用するAmqpTemplate
。- 戻り値:
- AmqpInboundGatewaySMLCSpec。
inboundGateway
public static AmqpInboundGatewayDMLCSpec inboundGateway(DirectMessageListenerContainer listenerContainer) 提供されたDirectMessageListenerContainer
で初期DirectMessageListenerContainerSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているDirectMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContainer- 戻り値:
- AmqpInboundGatewayDMLCSpec。
inboundGateway
public static AmqpInboundGatewayDMLCSpec inboundGateway(DirectMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) 提供されたDirectMessageListenerContainer
で初期AmqpInboundGatewayDMLCSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewayDMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているDirectMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContaineramqpTemplate
- 使用するAmqpTemplate
。- 戻り値:
- AmqpInboundGatewayDMLCSpec。
inboundPolledAdapter
public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(ConnectionFactory connectionFactory, StringSE queue) 初期 AmqpInboundPolledChannelAdapterSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。queue
- 待ち行列。- 戻り値:
- AmqpInboundPolledChannelAdapterSpec。
- 導入:
- 5.0.1
inboundPolledAdapter
public static AmqpInboundPolledChannelAdapterSpec inboundPolledAdapter(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, StringSE queue) 初期 AmqpInboundPolledChannelAdapterSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。ackCallbackFactory
- ackCallbackFactoryqueue
- 待ち行列。- 戻り値:
- AmqpInboundPolledChannelAdapterSpec。
- 導入:
- 5.0.1
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(ConnectionFactory connectionFactory, StringSE... queueNames) SimpleMessageListenerContainer
を使用して初期 AmqpInboundChannelAdapterSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。queueNames
- queueNames。- 戻り値:
- AmqpInboundChannelAdapterSpec。
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(ConnectionFactory connectionFactory, Queue... queues) SimpleMessageListenerContainer
を使用して初期 AmqpInboundChannelAdapterSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。queues
- キュー。- 戻り値:
- AmqpInboundChannelAdapterSpec。
inboundAdapter
public static AmqpInboundChannelAdapterSMLCSpec inboundAdapter(SimpleMessageListenerContainer listenerContainer) 提供されたSimpleMessageListenerContainer
で初期AmqpInboundGatewaySMLCSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているSimpleMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContainer- 戻り値:
- AmqpInboundGatewaySMLCSpec。
inboundAdapter
public static AmqpInboundChannelAdapterDMLCSpec inboundAdapter(DirectMessageListenerContainer listenerContainer) 提供されたDirectMessageListenerContainer
で初期AmqpInboundGatewayDMLCSpec
を作成します。注: 仕様ではエンドポイントオプションのみを使用できます。AmqpInboundGatewaySMLCSpec.configureContainer(java.util.function.Consumer)
を使用して、提供されているDirectMessageListenerContainer
でlistenerContainer
オプションを指定する必要があります。- パラメーター:
listenerContainer
- listenerContainer- 戻り値:
- AmqpInboundGatewaySMLCSpec。
outboundAdapter
初期 AmqpOutboundEndpointSpec(アダプター)を作成します。- パラメーター:
amqpTemplate
- amqpTemplate。- 戻り値:
- AmqpOutboundEndpointSpec。
outboundGateway
初期 AmqpOutboundEndpointSpec(ゲートウェイ)を作成します。- パラメーター:
amqpTemplate
- amqpTemplate。- 戻り値:
- AmqpOutboundEndpointSpec。
asyncOutboundGateway
public static AmqpAsyncOutboundGatewaySpec asyncOutboundGateway(AsyncRabbitTemplate asyncRabbitTemplate) 初期 AmqpAsyncOutboundGatewaySpec を作成します。- パラメーター:
asyncRabbitTemplate
-AsyncRabbitTemplate
- 戻り値:
- AmqpOutboundEndpointSpec。
pollableChannel
public static AmqpPollableMessageChannelSpec<?, PollableAmqpChannel> pollableChannel(ConnectionFactory connectionFactory) 初期 AmqpPollableMessageChannelSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。- 戻り値:
- AmqpPollableMessageChannelSpec。
pollableChannel
public static AmqpPollableMessageChannelSpec<?, PollableAmqpChannel> pollableChannel(@Nullable StringSE id, ConnectionFactory connectionFactory) 初期 AmqpPollableMessageChannelSpec を作成します。- パラメーター:
id
- ID。connectionFactory
- connectionFactory。- 戻り値:
- AmqpPollableMessageChannelSpec。
channel
初期 AmqpMessageChannelSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。- 戻り値:
- AmqpMessageChannelSpec。
channel
public static AmqpMessageChannelSpec<?,?> channel(@Nullable StringSE id, ConnectionFactory connectionFactory) 初期 AmqpMessageChannelSpec を作成します。- パラメーター:
id
- ID。connectionFactory
- connectionFactory。- 戻り値:
- AmqpMessageChannelSpec。
publishSubscribeChannel
public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(ConnectionFactory connectionFactory) 初期 AmqpPublishSubscribeMessageChannelSpec を作成します。- パラメーター:
connectionFactory
- connectionFactory。- 戻り値:
- AmqpPublishSubscribeMessageChannelSpec。
publishSubscribeChannel
public static AmqpPublishSubscribeMessageChannelSpec publishSubscribeChannel(@Nullable StringSE id, ConnectionFactory connectionFactory) 初期 AmqpPublishSubscribeMessageChannelSpec を作成します。- パラメーター:
id
- ID。connectionFactory
- connectionFactory。- 戻り値:
- AmqpPublishSubscribeMessageChannelSpec。