+ @Override
+ void handleForwardedLocalRequest(final AbstractLocalTransactionRequest<?> request,
+ final Consumer<Response<?, ?>> callback) {
+ if (request instanceof AbortLocalTransactionRequest) {
+ sendAbort(request, callback);
+ } else {
+ throw new IllegalArgumentException("Unhandled request" + request);
+ }
+ }
+