@Override public boolean dispatch(CallRunner task) throws IOException, InterruptedException { int priority = task.getCall().getPriority(); if (priority > HConstants.QOS_THRESHOLD) { numPriorityCalls++; } return super.dispatch(task); }
@Override public void dispatch(final CallRunner task) throws IOException, InterruptedException { executor.submit(new Runnable() { @Override public void run() { task.run(); } }); }
@Override public boolean dispatch(CallRunner task) throws IOException, InterruptedException { int priority = task.getRpcCall().getPriority(); if (priority > HConstants.QOS_THRESHOLD) { numPriorityCalls++; } return super.dispatch(task); }