クラス RequestReplyTypedMessageFuture<K,V,P>
java.lang.ObjectSE
java.util.concurrent.CompletableFutureSE<Message<?>>
org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>
org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,V,P>
- 型パラメーター:
K- 鍵の型。V- 送信データ型。P- 応答ペイロード型。
- 実装されたすべてのインターフェース:
CompletionStageSE<Message<?>>,FutureSE<Message<?>>
特定のペイロード型で応答する
Message のリッスン可能な未来。- 導入:
- 2.7
- 作成者:
- Gary Russell
ネストされたクラスのサマリー
クラス java.util.concurrent.CompletableFutureSE から継承されたネストクラス / インターフェース
CompletableFuture.AsynchronousCompletionTaskSEメソッドのサマリー
クラス org.springframework.kafka.requestreply.RequestReplyMessageFuture から継承されたメソッド
getSendFutureクラス 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, 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
メソッドの詳細
get
- 次で指定:
- インターフェース
FutureSE<K>のget - オーバーライド:
- クラス
CompletableFutureSE<Message<?>>のget - 例外:
InterruptedExceptionSEExecutionExceptionSE
get
public Message<P> get(long timeout, TimeUnitSE unit) throws InterruptedExceptionSE, ExecutionExceptionSE, TimeoutExceptionSE - 次で指定:
- インターフェース
FutureSE<K>のgetSE - オーバーライド:
- クラス
CompletableFutureSE<Message<?>>のgetSE - 例外:
InterruptedExceptionSEExecutionExceptionSETimeoutExceptionSE