インターフェース AmqpClient

方法の詳細

• send

  CompletableFutureSE<BooleanSE> send(org.apache.qpid.protonj2.client.Message<?> protonMessage)

  ProtonJ メッセージインスタンスを送信します。AmqpClient.Builder.defaultToAddress(String) が指定されている場合は、Message.to() は省略できます。

  パラメーター:

  protonMessage - 送信するメッセージ。

  戻り値:

  メッセージ決済結果。

• sendToDefault

  CompletableFutureSE<BooleanSE> sendToDefault(Message message)

  Spring AMQP メッセージを送信します。内部的に ProtonJ メッセージインスタンスに変換されます。これは AmqpClient.Builder.defaultToAddress(String) に基づいた便利な API です

  パラメーター:

  message - 送信するメッセージ。

  戻り値:

  メッセージ決済結果。

• to

  AmqpClient.SendSpec to(StringSE toAddress)

  to アドレスで始まるメッセージビルドブロックに基づいた送信操作用の Fluent API。

  パラメーター:

  toAddress - ターゲット AMQP 1.0 アドレス。

  戻り値:

  メッセージビルドブロックを備えた AmqpClient.SendSpec。

• from

  AmqpClient.ReceiveSpec from(StringSE fromAddress)

  from アドレスに基づいて受信操作を行う Fluent API。

  パラメーター:

  fromAddress - 送信元 AMQP 1.0 アドレス。

  戻り値:

  AmqpClient.ReceiveSpec

• create

  static AmqpClient create(AmqpConnectionFactory connectionFactory)

• builder

  static AmqpClient.Builder builder(AmqpConnectionFactory connectionFactory)