クラス AmqpInboundGateway

メソッドの詳細

• setMessageConverter

  public void setMessageConverter(MessageConverter messageConverter)

  MessageConverter を指定して、リクエストを変換し、Message との間で応答します。amqpTemplate が明示的に設定されている場合、この MessageConverter はそこに入力されません。その外部 amqpTemplate を構成する必要があります。

  パラメーター:

  messageConverter - 使用する MessageConverter。

• setHeaderMapper

  public void setHeaderMapper(AmqpHeaderMapper headerMapper)

• setDefaultReplyTo

  public void setDefaultReplyTo(StringSE defaultReplyTo)

  次の形式の defaultReplyTo アドレス

   (exchange)/(routingKey)
   

  または

   (queueName)
   

  リクエストメッセージに replyTo プロパティがない場合。2 番目の形式は、デフォルトの交換（""）とキュー名をルーティングキーとして使用します。

  パラメーター:

  defaultReplyTo - 使用するデフォルトの replyTo アドレス。

  導入:

  4.2

  関連事項:

  • Address

• setRetryTemplate

  public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

  ゲートウェイ内でのメッセージ配信の再試行に使用する RetryTemplate を設定します。コンテナーレベルでの再試行の追加とは異なり、これを ErrorMessageSendingRecovererRecoveryCallback とともに使用して、再試行が終了した後にエラーチャネルに公開できます。通常、ここで再試行を使用する場合はエラーチャネルを設定しないでください。代わりに、RecoveryCallback を使用してください。

  パラメーター:

  retryTemplate - テンプレート。

  導入:

  4.3.10.

  関連事項:

  • setRecoveryCallback(RecoveryCallback)

• setRecoveryCallback

  public void setRecoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)

  ゲートウェイ内で再試行を使用する場合は、RecoveryCallback を設定します。setMessageRecoverer(MessageRecoverer) と相互に排他的です。

  パラメーター:

  recoveryCallback - コールバック。

  導入:

  4.3.10

  関連事項:

  • setRetryTemplate(RetryTemplate)

• setMessageRecoverer

  public void setMessageRecoverer(MessageRecoverer messageRecoverer)

  再試行操作用に MessageRecoverer を構成します。setRecoveryCallback(RecoveryCallback) の代わりに AMQP 固有の便利さ。

  パラメーター:

  messageRecoverer - 使用する MessageRecoverer。

  導入:

  5.5

• setBatchingStrategy

  public void setBatchingStrategy(BatchingStrategy batchingStrategy)

  メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。デフォルトは SimpleBatchingStrategy です。

  パラメーター:

  batchingStrategy - 戦略。

  導入:

  5.2

• setBindSourceMessage

  public void setBindSourceMessage(boolean bindSourceMessage)

  IntegrationMessageHeaderAccessor.SOURCE_DATA という名前のヘッダーのソースメッセージをバインドするには、true に設定します。

  パラメーター:

  bindSourceMessage - バインドする場合は true。

  導入:

  5.1.6

• setReplyHeadersMappedLast

  public void setReplyHeadersMappedLast(boolean replyHeadersMappedLast)

  送信（返信）メッセージのヘッダーをマッピングするときは、メッセージが変換される前にヘッダーをマッピングするか、後で変換するかを決定します。これは、メッセージコンバーターによって追加される可能性のあるヘッダーにのみ影響します。false の場合、コンバーターのヘッダーが優先されます。true の場合、コンバーターによって追加されたヘッダーはオーバーライドされます（ソースメッセージにそれらのヘッダーにマップするヘッダーがある場合）。たとえば、json を含む文字列ペイロードで SimpleMessageConverter を使用する場合、これを true に設定することができます。コンバーターはコンテンツ型を text/plain に設定します。これは、AmqpHeaders.CONTENT_TYPE メッセージヘッダーを設定することにより、application/json にオーバーライドできます。デフォルト: false。

  パラメーター:

  replyHeadersMappedLast - 変換後に応答ヘッダーがマップされる場合は true。

  導入:

  5.1.9

• getComponentType

  public StringSE getComponentType()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。

  次で指定:

  インターフェース NamedComponent の getComponentType 

  オーバーライド:

  クラス MessagingGatewaySupport の getComponentType 

• onInit

  protected void onInit()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスは、初期化ロジック用にこれを実装できます。

  オーバーライド:

  クラス MessagingGatewaySupport の onInit 

• doStart

  protected void doStart()

  クラスからコピーされた説明: AbstractEndpoint

  サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。

  オーバーライド:

  クラス MessagingGatewaySupport の doStart 

• doStop

  protected void doStop()

  クラスからコピーされた説明: AbstractEndpoint

  サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。

  オーバーライド:

  クラス MessagingGatewaySupport の doStop 

• getErrorMessageAttributes

  protected AttributeAccessor getErrorMessageAttributes(Message<?> message)

  クラスからコピーされた説明: MessagingGatewaySupport

  errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。

  オーバーライド:

  クラス MessagingGatewaySupport の getErrorMessageAttributes 

  パラメーター:

  message - メッセージ。

  戻り値:

  属性。