if (it.hasNext()) {
return fetchSource(sourceId, it);
}
- throw new MissingSchemaSourceException("All available providers exhausted", sourceId, input);
+ throw new MissingSchemaSourceException(sourceId, "All available providers exhausted", input);
}, MoreExecutors.directExecutor());
}
synchronized (this) {
final var srcs = sources.get(id);
if (srcs == null) {
- return immediateFailedFluentFuture(new MissingSchemaSourceException(
- "No providers registered for source " + id, id));
+ return immediateFailedFluentFuture(new MissingSchemaSourceException(id,
+ "No providers registered for source " + id));
}
sortedSchemaSourceRegistrations = new ArrayList<>(srcs.get(representation));
final var regs = sortedSchemaSourceRegistrations.iterator();
if (!regs.hasNext()) {
- return immediateFailedFluentFuture(new MissingSchemaSourceException(
- "No providers for source " + id + " representation " + representation + " available", id));
+ return immediateFailedFluentFuture(new MissingSchemaSourceException(id,
+ "No providers for source " + id + " representation " + representation + " available"));
}
final ListenableFuture<T> fetchSourceFuture = fetchSource(id, regs);