- /**
- * Invalidate previously-resolved shard information. This method is invoked when a timeout is detected
- * and the information may need to be refreshed.
- *
- * @param info Previous promise of backend information
- */
- protected abstract void invalidateBackendInfo(@Nonnull CompletionStage<? extends BackendInfo> info);
-
- // This is what the client needs to start processing. For as long as we do not have this, we should not complete
- // this stage until we have this information
- final CompletionStage<? extends T> getBackendInfo(final Long cookie) {
- return lookupBackend(cookie);
- }