クラス 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