クラス 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.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, failedFutureSE, failedStageSE, get, getSE, getNowSE, getNumberOfDependents, handleSE, handleAsyncSE, handleAsyncSE, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeExceptionSE, obtrudeValueSE, orTimeoutSE, runAfterBothSE, runAfterBothAsyncSE, runAfterBothAsyncSE, runAfterEitherSE, runAfterEitherAsyncSE, runAfterEitherAsyncSE, runAsyncSE, runAsyncSE, 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
送信先を返します。- 戻り値:
- 未来を送る。