クラス 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
- 例外:
InterruptedExceptionSE
ExecutionExceptionSE
get
public Message<P> get(long timeout, TimeUnitSE unit) throws InterruptedExceptionSE, ExecutionExceptionSE, TimeoutExceptionSE - 次で指定:
- インターフェース
FutureSE<K>
のgetSE
- オーバーライド:
- クラス
CompletableFutureSE<Message<?>>
のgetSE
- 例外:
InterruptedExceptionSE
ExecutionExceptionSE
TimeoutExceptionSE