クラス RequestReplyFuture<K,V,R>
java.lang.ObjectSE
java.util.concurrent.CompletableFutureSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
org.springframework.kafka.requestreply.RequestReplyFuture<K,V,R>
- 型パラメーター:
K- 鍵の型。V- 送信データ型。R- 応答データ型。
- 実装されているすべてのインターフェース:
CompletionStageSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,,R>> FutureSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
public class RequestReplyFuture<K,V,R>
extends CompletableFutureSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
リクエスト / 応答用の
CompletableFutureSE。- 導入:
- 2.1.3
- 作成者:
- Gary Russell
ネストされたクラスの要約
クラス java.util.concurrent.CompletableFutureSE から継承されたネストクラス / インターフェース
CompletableFuture.AsynchronousCompletionTaskSEインターフェース java.util.concurrent.FutureSE から継承されたネストクラス / インターフェース
Future.StateSEコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明@Nullable CompletableFutureSE<SendResult<K, V>> 送信先を返します。protected voidsetSendFuture(CompletableFutureSE<SendResult<K, V>> sendFuture) クラス java.util.concurrent.CompletableFutureSE から継承されたメソッド
acceptEitherSE, acceptEitherAsyncSE, acceptEitherAsyncSE, allOfSE, anyOfSE, applyToEitherSE, applyToEitherAsyncSE, applyToEitherAsyncSE, cancelSE, completeSE, completeAsyncSE, completeAsyncSE, completedFutureSE, completedStageSE, completeExceptionallySE, completeOnTimeoutSE, copy, defaultExecutor, delayedExecutorSE, delayedExecutorSE, exceptionallySE, exceptionallyAsyncSE, exceptionallyAsyncSE, exceptionallyComposeSE, exceptionallyComposeAsyncSE, exceptionallyComposeAsyncSE, exceptionNow, failedFutureSE, failedStageSE, get, getSE, getNowSE, getNumberOfDependents, handleSE, handleAsyncSE, handleAsyncSE, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeExceptionSE, obtrudeValueSE, orTimeoutSE, resultNow, runAfterBothSE, runAfterBothAsyncSE, runAfterBothAsyncSE, runAfterEitherSE, runAfterEitherAsyncSE, runAfterEitherAsyncSE, runAsyncSE, runAsyncSE, state, supplyAsyncSE, supplyAsyncSE, thenAcceptSE, thenAcceptAsyncSE, thenAcceptAsyncSE, thenAcceptBothSE, thenAcceptBothAsyncSE, thenAcceptBothAsyncSE, thenApplySE, thenApplyAsyncSE, thenApplyAsyncSE, thenCombineSE, thenCombineAsyncSE, thenCombineAsyncSE, thenComposeSE, thenComposeAsyncSE, thenComposeAsyncSE, thenRunSE, thenRunAsyncSE, thenRunAsyncSE, toCompletableFuture, toString, whenCompleteSE, whenCompleteAsyncSE, whenCompleteAsyncSE
コンストラクターの詳細
RequestReplyFuture
public RequestReplyFuture()
メソッドの詳細
setSendFuture
getSendFuture