クラス AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>>

方法の詳細

• messageConverter

  public S messageConverter(MessageConverter messageConverter)

  ゲートウェイの MessageConverter を構成します。; デフォルトは SimpleMessageConverter です。

  パラメーター:

  messageConverter - messageConverter。

  戻り値:

  スペック。

  関連事項:

  • AmqpInboundGateway.setMessageConverter(MessageConverter)

• headerMapper

  public S headerMapper(AmqpHeaderMapper headerMapper)

  ゲートウェイの AmqpHeaderMapper を構成します。; デフォルトは DefaultAmqpHeaderMapper です。

  パラメーター:

  headerMapper - headerMapper。

  戻り値:

  スペック。

  関連事項:

  • AmqpInboundGateway.setHeaderMapper(AmqpHeaderMapper)

• mappedRequestHeaders

  public S mappedRequestHeaders(StringSE... headers)

  デフォルトのヘッダーマッパーが使用されている場合にのみ適用されます。

  パラメーター:

  headers - ヘッダー。

  戻り値:

  スペック。

  関連事項:

  • AbstractHeaderMapper.setRequestHeaderNames(String[])

• mappedReplyHeaders

  public S mappedReplyHeaders(StringSE... headers)

  デフォルトのヘッダーマッパーが使用されている場合にのみ適用されます。

  パラメーター:

  headers - ヘッダー。

  戻り値:

  スペック。

  関連事項:

  • AbstractHeaderMapper.setReplyHeaderNames(String[])

• defaultReplyTo

  public S defaultReplyTo(StringSE defaultReplyTo)

  次の形式の defaultReplyTo アドレス

  (exchange)/(routingKey)
  

  または

  (queueName)
  

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

  パラメーター:

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

  戻り値:

  スペック。

  関連事項:

  • AmqpInboundGateway.setDefaultReplyTo(String)

• retryTemplate

  public S retryTemplate(RetryTemplate retryTemplate)

  アダプター内でメッセージ配信を再試行するために使用する RetryTemplate を設定します。

  パラメーター:

  retryTemplate - テンプレート。

  戻り値:

  スペック。

  導入:

  5.0.2

  関連事項:

  • AmqpInboundGateway.setRetryTemplate(RetryTemplate)

• recoveryCallback

  public S recoveryCallback(RecoveryCallback<?> recoveryCallback)

  アダプター内で再試行を使用する場合は、RecoveryCallback を設定してください。

  パラメーター:

  recoveryCallback - コールバック。

  戻り値:

  スペック。

  導入:

  5.0.2

  関連事項:

  • AmqpInboundGateway.setRecoveryCallback(RecoveryCallback)

• batchingStrategy

  public S batchingStrategy(BatchingStrategy batchingStrategy)

  メッセージをバッチ解除するときに使用するバッチ処理戦略を設定します。

  パラメーター:

  batchingStrategy - 使用する戦略。

  戻り値:

  スペック。

  導入:

  5.2.1

  関連事項:

  • AmqpInboundGateway.setBatchingStrategy(BatchingStrategy)

• bindSourceMessage

  public S bindSourceMessage(boolean bindSourceMessage)

  true に設定すると、ヘッダーのソースメッセージがバインドされます。

  パラメーター:

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

  戻り値:

  スペック。

  導入:

  5.1.9

  関連事項:

  • AmqpInboundGateway.setBindSourceMessage(boolean)

• replyHeadersMappedLast

  public S replyHeadersMappedLast(boolean replyHeadersMappedLast)

  送信（返信）メッセージのヘッダーをマッピングするときは、メッセージが変換される前にヘッダーをマッピングするか、後で変換するかを決定します。

  パラメーター:

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

  戻り値:

  スペック。

  導入:

  5.1.9

  関連事項:

  • AmqpInboundGateway.setReplyHeadersMappedLast(boolean)

• messageRecoverer

  public S messageRecoverer(MessageRecoverer messageRecoverer)

  アダプター内で再試行を使用する場合は、MessageRecoverer を設定してください。

  パラメーター:

  messageRecoverer - コールバック。

  戻り値:

  スペック。

  導入:

  5.5

  関連事項:

  • AmqpInboundChannelAdapter.setMessageRecoverer(MessageRecoverer)