クラス AmqpClientMessageHandlerSpec

メソッドの詳細

• headerMapper

  public AmqpClientMessageHandlerSpec headerMapper(AmqpHeaderMapper headerMapper)

  リクエスト (および応答) ヘッダーをマップするには、AmqpHeaderMapper を設定します。

  パラメーター:

  headerMapper - 使用する AmqpHeaderMapper。

  戻り値:

  スペック

• messageConverter

  public AmqpClientMessageHandlerSpec messageConverter(MessageConverter messageConverter)

  デフォルトの SimpleMessageConverter を置き換える MessageConverter を設定します。null に設定した場合、AMQP メッセージはそのままメッセージペイロードに送信されます。応答メッセージは、ペイロードとして AMQP メッセージを返す必要があります。

  パラメーター:

  messageConverter - 使用する MessageConverter または null。

  戻り値:

  スペック

• exchange

  public AmqpClientMessageHandlerSpec exchange(StringSE exchange)

  リクエストメッセージを公開するための交換を設定します。queue(String) とは排他的です。

  パラメーター:

  exchange - 交換機にリクエストメッセージを送信します。

  戻り値:

  スペック

• exchangeFunction

  public <P> AmqpClientMessageHandlerSpec exchangeFunction(FunctionSE<Message<P>, StringSE> exchangeFunction)

  実行時にリクエストメッセージを公開するための交換を決定する関数を設定します。queue(String) とは排他的です。

  パラメーター:

  exchangeFunction - リクエストメッセージに対する交換を決定する機能。

  戻り値:

  スペック

• exchangeExpression

  public AmqpClientMessageHandlerSpec exchangeExpression(Expression exchangeExpression)

  実行時にリクエストメッセージを公開するための交換を決定する SpEL 式を設定します。queue(String) とは排他的です。

  パラメーター:

  exchangeExpression - リクエストメッセージに対する交換を決定する SpEL 式。

  戻り値:

  スペック

• exchangeExpression

  public AmqpClientMessageHandlerSpec exchangeExpression(StringSE exchangeExpression)

  実行時にリクエストメッセージを公開するための交換を決定する SpEL 式を設定します。queue(String) とは排他的です。

  パラメーター:

  exchangeExpression - リクエストメッセージに対する交換を決定する SpEL 式。

  戻り値:

  スペック

• routingKey

  public AmqpClientMessageHandlerSpec routingKey(StringSE routingKey)

  リクエストメッセージを公開するためのルーティングキーを設定します。exchange(String) と組み合わせてのみ使用されます。

  パラメーター:

  routingKey - リクエストメッセージを送信するためのルーティングキー。

  戻り値:

  スペック

• routingKeyFunction

  public <P> AmqpClientMessageHandlerSpec routingKeyFunction(FunctionSE<Message<P>, StringSE> routingKeyFunction)

  実行時にリクエストメッセージを公開するためのルーティングキーを決定する関数を設定します。queue(String) とは排他的です。exchange(String) とのみ併用されます。

  パラメーター:

  routingKeyFunction - リクエストメッセージに対してルーティングキーを決定する機能。

  戻り値:

  スペック

• routingKeyExpression

  public AmqpClientMessageHandlerSpec routingKeyExpression(StringSE routingKeyExpression)

  実行時にリクエストメッセージを公開するためのルーティングキーを決定するための SpEL 式を設定します。queue(String) とは排他的です。exchange(String) とのみ併用されます。

  パラメーター:

  routingKeyExpression - リクエストメッセージに対してルーティングキーを決定する SpEL 式。

  戻り値:

  スペック

• routingKeyExpression

  public AmqpClientMessageHandlerSpec routingKeyExpression(Expression routingKeyExpression)

  実行時にリクエストメッセージを公開するためのルーティングキーを決定する SpEL 式を設定します。queue(String) とは排他的です。exchange(String) とのみ併用されます。

  パラメーター:

  routingKeyExpression - SpEL 式は、リクエストメッセージに対するルーティングキーを決定します。

  戻り値:

  スペック

• queue

  public AmqpClientMessageHandlerSpec queue(StringSE queue)

  リクエストメッセージを公開するためのキューを設定します。exchange(String) とは排他的です。

  パラメーター:

  queue - リクエストメッセージを送信するキュー。

  戻り値:

  スペック

• queueExpression

  public AmqpClientMessageHandlerSpec queueExpression(StringSE queueExpression)

  実行時にリクエストメッセージを公開するためのキューを決定するための SpEL 式を設定します。exchange(String) とは排他的です。

  パラメーター:

  queueExpression - リクエストメッセージに対してキューを決定する SpEL 式。

  戻り値:

  スペック

• queueFunction

  public <P> AmqpClientMessageHandlerSpec queueFunction(FunctionSE<Message<P>, StringSE> queueFunction)

  実行時にリクエストメッセージを公開するためのキューを決定する関数を設定します。exchange(String) とは排他的です。

  パラメーター:

  queueFunction - リクエストメッセージに対してキューを決定する機能。

  戻り値:

  スペック

• queueExpression

  public AmqpClientMessageHandlerSpec queueExpression(Expression queueExpression)

  実行時にリクエストメッセージを公開するためのキューを決定するための SpEL 式を設定します。exchange(String) とは排他的です。

  パラメーター:

  queueExpression - リクエストメッセージに対してキューを決定する SpEL 式。

  戻り値:

  スペック

• replyPayloadType

  public AmqpClientMessageHandlerSpec replyPayloadType(ClassSE<?> replyPayloadType)

  応答ペイロードの種類を設定します。ゲートウェイモードでのみ使用されます。

  パラメーター:

  replyPayloadType - 応答ペイロード型。

  戻り値:

  スペック

• replyPayloadType

  public AmqpClientMessageHandlerSpec replyPayloadType(ResolvableType replyPayloadType)

  応答ペイロードの種類を設定します。ゲートウェイモードでのみ使用されます。

  パラメーター:

  replyPayloadType - 応答ペイロード型。

  戻り値:

  スペック

• replyPayloadTypeExpression

  public AmqpClientMessageHandlerSpec replyPayloadTypeExpression(StringSE replyPayloadTypeExpression)

  応答ペイロード型の SpEL 式を設定します。ゲートウェイモードでのみ使用されます。ClassSE または ResolvableType に評価される必要があります。

  パラメーター:

  replyPayloadTypeExpression - 応答ペイロード型の表現。

  戻り値:

  スペック

• replyPayloadTypeFunction

  public <P> AmqpClientMessageHandlerSpec replyPayloadTypeFunction(FunctionSE<Message<P>, ?> replyPayloadTypeFunction)

  応答ペイロード型の関数を設定します。ゲートウェイモードでのみ使用されます。ClassSE または ResolvableType として評価される必要があります。

  パラメーター:

  replyPayloadTypeFunction - 応答ペイロード型の表現。

  戻り値:

  スペック

• replyPayloadTypeExpression

  public AmqpClientMessageHandlerSpec replyPayloadTypeExpression(Expression replyPayloadTypeExpression)

  応答ペイロード型の SpEL 式を設定します。ゲートウェイモードでのみ使用されます。ClassSE または ResolvableType に評価される必要があります。

  パラメーター:

  replyPayloadTypeExpression - 応答ペイロード型の表現。

  戻り値:

  スペック

• returnMessage

  public AmqpClientMessageHandlerSpec returnMessage(boolean returnMessage)

  AMQP メッセージ全体を応答として返すには、true に設定します。ゲートウェイモードでのみ使用されます。

  パラメーター:

  returnMessage - 応答を AMQP メッセージ全体として返す場合は true です。

  戻り値:

  スペック