クラス Amqp
java.lang.ObjectSE
org.springframework.integration.amqp.dsl.Amqp
AMQP コンポーネントのファクトリクラス。
- 導入:
- 5.0
- 作成者:
- Artem Bilan, Gary Russell, Artem Vozhdayenko
メソッドのサマリー
修飾子と型メソッド説明static AmqpAsyncOutboundGatewaySpecasyncOutboundGateway(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 AmqpInboundGatewaySMLCSpecinboundGateway(ConnectionFactory connectionFactory, StringSE... queueNames) 初期AmqpInboundGatewaySpecを作成します。static AmqpInboundGatewaySMLCSpecinboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, StringSE... queueNames) 初期AmqpInboundGatewaySpecを作成します。static AmqpInboundGatewaySMLCSpecinboundGateway(ConnectionFactory connectionFactory, AmqpTemplate amqpTemplate, Queue... queues) 初期AmqpInboundGatewaySpecを作成します。static AmqpInboundGatewaySMLCSpecinboundGateway(ConnectionFactory connectionFactory, Queue... queues) 初期AmqpInboundGatewaySpecを作成します。static AmqpInboundGatewayDMLCSpecinboundGateway(DirectMessageListenerContainer listenerContainer) 提供されたDirectMessageListenerContainerで初期DirectMessageListenerContainerSpecを作成します。static AmqpInboundGatewayDMLCSpecinboundGateway(DirectMessageListenerContainer listenerContainer, AmqpTemplate amqpTemplate) 提供されたDirectMessageListenerContainerで初期AmqpInboundGatewayDMLCSpecを作成します。static AmqpInboundGatewaySMLCSpecinboundGateway(SimpleMessageListenerContainer listenerContainer) 提供されたSimpleMessageListenerContainerで初期AmqpInboundGatewaySMLCSpecを作成します。static AmqpInboundGatewaySMLCSpecinboundGateway(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 AmqpOutboundGatewaySpecoutboundGateway(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。