public abstract class AbstractSilentErrorService<I, O extends DataObject>
extends AbstractSimpleService<I, O> {
- protected AbstractSilentErrorService(RequestContextStack requestContextStack, DeviceContext deviceContext, Class<O> clazz) {
+ protected AbstractSilentErrorService(RequestContextStack requestContextStack,
+ DeviceContext deviceContext,
+ Class<O> clazz) {
super(requestContextStack, deviceContext, clazz);
}
@Override
public ListenableFuture<RpcResult<O>> handleServiceCall(@Nonnull I input,
@Nullable final Function<OfHeader, Boolean> isComplete) {
- return Futures.withFallback(
- super.handleServiceCall(input, isComplete),
- t -> RpcResultBuilder.<O>failed().buildFuture());
+ return Futures.catching(
+ super.handleServiceCall(input, isComplete),
+ Throwable.class,
+ t -> RpcResultBuilder.<O>failed().build());
}
-
}