@Override public DoRollbackResponseProto doRollback(RpcController controller, DoRollbackRequestProto request) throws ServiceException { try { impl.doRollback(convert(request.getJid())); return DoRollbackResponseProto.getDefaultInstance(); } catch (IOException e) { throw new ServiceException(e); } }
@Override public void doRollback(String journalId) throws IOException { try { rpcProxy.doRollback(NULL_CONTROLLER, DoRollbackRequestProto.newBuilder() .setJid(convertJournalId(journalId)) .build()); } catch (ServiceException e) { throw ProtobufHelper.getRemoteException(e); } }