private static class ExtendedResolver.Resolution
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private int[] |
attempts |
private int |
currentResolver |
private long |
endTime |
private Message |
query |
private java.util.List<ExtendedResolver.ResolverEntry> |
resolvers |
private int |
retriesPerResolver |
Constructor and Description |
---|
Resolution(ExtendedResolver eres,
Message query) |
Modifier and Type | Method and Description |
---|---|
private java.util.concurrent.CompletionStage<Message> |
handle(Message result,
java.lang.Throwable ex,
java.util.concurrent.Executor executorService) |
private java.util.concurrent.CompletionStage<Message> |
send(java.util.concurrent.Executor executorService) |
private java.util.concurrent.CompletionStage<Message> |
startAsync(java.util.concurrent.Executor executorService) |
private final Message query
private final int[] attempts
private final int retriesPerResolver
private final long endTime
private java.util.List<ExtendedResolver.ResolverEntry> resolvers
private int currentResolver
Resolution(ExtendedResolver eres, Message query)