AmqpOutboundEndpoint (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.handler.MessageHandlerSupport
  - - org.springframework.integration.handler.AbstractMessageHandler
    - - org.springframework.integration.handler.AbstractMessageProducingHandler
      - org.springframework.integration.handler.AbstractReplyProducingMessageHandler
        
        org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint
        
        org.springframework.integration.amqp.outbound.AmqpOutboundEndpoint

実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>, RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback, RabbitTemplate.ReturnsCallback, Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
```
public class AmqpOutboundEndpoint
extends AbstractAmqpOutboundEndpoint
implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnsCallback
```
メッセージを変換して AMQPExchange に送信するアダプター。
導入:
2.1
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

ネストされたクラスのサマリー
- クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたネストクラス / インターフェース
  AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
- クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース
  AbstractReplyProducingMessageHandler.RequestHandler
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
  IntegrationManagement.ManagementOverrides

フィールドのサマリー
- クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
  messagingTemplate
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.core.Ordered から継承されたフィールド
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
  METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

コンストラクターの概要
コンストラクター
コンストラクターと説明
AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)

コンストラクター
コンストラクターと説明
`AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`void`	`confirm(CorrelationData correlationData, boolean ack, StringSE cause)`
`protected void`	`doStop()`
`protected void`	`endpointInit()` サブクラスはオーバーライドして、追加の初期化を実行できます。
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`IntegrationPatternType`	`getIntegrationPatternType()` このコンポーネントが実装するパターン型を返します。
`RabbitTemplate`	`getRabbitTemplate()`
`protected ObjectSE`	`handleRequestMessage(Message<?> requestMessage)` サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。
`void`	`returnedMessage(ReturnedMessage returnedMessage)`
`void`	`setExpectReply(boolean expectReply)` このエンドポイントがゲートウェイの場合は true に設定します。
`void`	`setMultiSend(boolean multiSend)` true で、メッセージペイロードが `Message` の `Iterable`SE である場合、テンプレートの 1 回の呼び出し（同じチャネル）でメッセージを送信し、オプションで確認を待つか、終了するか、トランザクション内のすべての送信を実行します（既存または新規）。
`void`	`setWaitForConfirm(boolean waitForConfirm)` パブリッシャーの確認が受信されるまで呼び出しスレッドをブロックする場合は、true に設定します。

クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたメソッド
addDelayProperty, buildReply, buildReturnedMessage, buildReturnedMessage, doInit, doStart, generateCorrelationData, generateExchangeName, generateRoutingKey, getConfirmAckChannel, getConfirmCorrelationExpression, getConfirmNackChannel, getConfirmTimeout, getCorrelationDataGenerator, getDefaultDeliveryMode, getExchangeName, getExchangeNameExpression, getExchangeNameGenerator, getHeaderMapper, getReturnChannel, getRoutingKey, getRoutingKeyExpression, getRoutingKeyGenerator, handleConfirm, isHeadersMappedLast, isLazyConnect, isRunning, setConfirmAckChannel, setConfirmAckChannelName, setConfirmCorrelationExpression, setConfirmCorrelationExpressionString, setConfirmNackChannel, setConfirmNackChannelName, setConfirmTimeout, setConnectionFactory, setDefaultDeliveryMode, setDelay, setDelayExpression, setDelayExpressionString, setErrorMessageStrategy, setExchangeName, setExchangeNameExpression, setExchangeNameExpressionString, setHeaderMapper, setHeadersMappedLast, setLazyConnect, setReturnChannel, setRoutingKey, setRoutingKeyExpression, setRoutingKeyExpressionString, start, stop

クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたメソッド
doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback から継承されたメソッド
delegate, returnedMessage

インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- コンストラクターの詳細
  - AmqpOutboundEndpoint
```
public AmqpOutboundEndpoint(AmqpTemplate amqpTemplate)
```
- メソッドの詳細
  - setExpectReply
```
public void setExpectReply(boolean expectReply)
```
    このエンドポイントがゲートウェイの場合は true に設定します。
    パラメーター:
    expectReply - ゲートウェイの場合は true。
  - setWaitForConfirm
```
public void setWaitForConfirm(boolean waitForConfirm)
```
    パブリッシャーの確認が受信されるまで呼び出しスレッドをブロックする場合は、true に設定します。return 用に構成されたテンプレートが必要です。確認タイムアウト内に確認が受信されない場合、または否定応答または返されたメッセージが受信された場合、例外がスローされます。ゲートウェイは応答の待機をブロックするため、ゲートウェイには適用されません。
    パラメーター:
    waitForConfirm - 確認またはタイムアウトが受信されるまでブロックする場合は true。
    導入:
    5.2
    関連事項:
    AbstractAmqpOutboundEndpoint.setConfirmTimeout(long), setMultiSend(boolean)
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス MessageHandlerSupport の getComponentType
  - setMultiSend
```
public void setMultiSend(boolean multiSend)
```
    true で、メッセージペイロードが Message の IterableSE である場合、テンプレートの 1 回の呼び出し（同じチャネル）でメッセージを送信し、オプションで確認を待つか、終了するか、トランザクション内のすべての送信を実行します（既存または新規）。
    パラメーター:
    multiSend - 複数のメッセージを送信する場合は true。
    導入:
    5.3
    関連事項:
    setWaitForConfirm(boolean)
  - getIntegrationPatternType
```
public IntegrationPatternType getIntegrationPatternType()
```
    インターフェースからコピーされた説明: IntegrationPattern
    このコンポーネントが実装するパターン型を返します。
    次で指定:
    インターフェース IntegrationPattern の getIntegrationPatternType
    オーバーライド:
    クラス AbstractReplyProducingMessageHandler の getIntegrationPatternType
    戻り値:
    このコンポーネントが実装する IntegrationPatternType
  - getRabbitTemplate
```
public RabbitTemplate getRabbitTemplate()
```
    次で指定:
    クラス AbstractAmqpOutboundEndpoint の getRabbitTemplate
  - endpointInit
```
protected void endpointInit()
```
    クラスからコピーされた説明: AbstractAmqpOutboundEndpoint
    サブクラスはオーバーライドして、追加の初期化を実行できます。afterPropertiesSet() から呼び出されます。
    オーバーライド:
    クラス AbstractAmqpOutboundEndpoint の endpointInit
  - doStop
```
protected void doStop()
```
    オーバーライド:
    クラス AbstractAmqpOutboundEndpoint の doStop
  - handleRequestMessage
```
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
```
    クラスからコピーされた説明: AbstractReplyProducingMessageHandler
    サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
    次で指定:
    クラス AbstractReplyProducingMessageHandler の handleRequestMessage
    パラメーター:
    requestMessage - リクエストメッセージ。
    戻り値:
    メッセージを処理した結果、または null
  - confirm
```
public void confirm(CorrelationData correlationData,
                    boolean ack,
                    StringSE cause)
```
    次で指定:
    インターフェース RabbitTemplate.ConfirmCallback の confirm
  - returnedMessage
```
public void returnedMessage(ReturnedMessage returnedMessage)
```
    次で指定:
    インターフェース RabbitTemplate.ReturnCallback の returnedMessage
    次で指定:
    インターフェース RabbitTemplate.ReturnsCallback の returnedMessage

クラス AmqpOutboundEndpoint

ネストされたクラスのサマリー

クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたネストクラス / インターフェース

クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.core.Ordered から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたメソッド

クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback から継承されたメソッド

インターフェース reactor.core.CoreSubscriber から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

AmqpOutboundEndpoint

メソッドの詳細

setExpectReply

setWaitForConfirm

getComponentType

setMultiSend

getIntegrationPatternType

getRabbitTemplate

endpointInit

doStop

handleRequestMessage

confirm

returnedMessage