クラス AmqpClient.Builder
java.lang.ObjectSE
org.springframework.amqp.client.AmqpClient.Builder
- 含まれているインターフェース:
- AmqpClient
方法の概要
修飾子と型メソッド説明build()提供されたオプションに基づいてAmqpClientインスタンスを構築します。completionTimeout(DurationSE completionTimeout) リターン時にCompletableFuture.orTimeout(long, TimeUnit)SE の期間を設定します。defaultToAddress(StringSE defaultToAddress) AmqpClient.sendToDefault(org.springframework.amqp.core.Message)およびAmqpClient.send(Message)操作のデフォルトのターゲット AMQP 1.0 アドレスを設定します。messageConverter(MessageConverter messageConverter) メッセージ本文との変換に使用するMessageConverterを設定します。senderOptions(ConsumerSE<org.apache.qpid.protonj2.client.SenderOptions> senderOptionsCustomizer) このビルダーでSenderOptionsインスタンスをカスタマイズします。senderOptions(org.apache.qpid.protonj2.client.SenderOptions senderOptions) 内部 AMQP 1.0SenderのSenderOptionsを設定します。taskExecutor(TaskExecutor taskExecutor) 非同期操作の場合はTaskExecutorを設定します。
方法の詳細
senderOptions
public AmqpClient.Builder senderOptions(org.apache.qpid.protonj2.client.SenderOptions senderOptions) 内部 AMQP 1.0Senderに対してSenderOptionsを設定します。既存のインスタンスを上書きします。- パラメーター:
senderOptions- 使用します。- 戻り値:
- このビルダー。
- 関連事項:
senderOptions
public AmqpClient.Builder senderOptions(ConsumerSE<org.apache.qpid.protonj2.client.SenderOptions> senderOptionsCustomizer) このビルダーでSenderOptionsインスタンスをカスタマイズします。senderOptions(SenderOptions)を呼び出すと、既存のインスタンスが上書きされます。- パラメーター:
senderOptionsCustomizer- the consumer to accept existingSenderOptions.- 戻り値:
- このビルダー。
- 関連事項:
completionTimeout
リターン時のCompletableFuture.orTimeout(long, TimeUnit)SE の継続時間を設定します。CompletableFuture.get(long, TimeUnit)SE からリクエストされるonTimeout()のようなCompletableFutureSE API はありませんが、CompletableFutureSE のフルフィルメントとは独立して、AMQP リソースを最終的に閉じる必要がある操作で使用されます。デフォルトは 1 分です。- パラメーター:
completionTimeout- 将来の完了までの期間。- 戻り値:
- このビルダー。
defaultToAddress
AmqpClient.sendToDefault(org.springframework.amqp.core.Message)およびAmqpClient.send(Message)操作のデフォルトのターゲット AMQP 1.0 アドレスを設定します。- パラメーター:
defaultToAddress- 便利なデフォルトとして使用するターゲットアドレス。- 戻り値:
- このビルダー。
messageConverter
メッセージ本文との変換に使用するMessageConverterを設定します。ObjectSE 以外のジェネリクス型を持つAmqpClient.ReceiveSpec.receiveAndConvert(T...)の場合、このコンバーターはSmartMessageConverterである必要があります。- パラメーター:
messageConverter- コンバーター。- 戻り値:
- このビルダー。
taskExecutor
非同期操作用にTaskExecutorを設定します。デフォルトでは、1 つのコアプールスレッドを持つThreadPoolExecutorSE が使用されます。- パラメーター:
taskExecutor- タスクエグゼキュータ。- 戻り値:
- このビルダー。
build
提供されたオプションに基づいてAmqpClientインスタンスを構築します。- 戻り値:
- クライアントインスタンス。