MockCommitProcessor() { super( new RequestProcessor() { public void processRequest(Request request) throws RequestProcessorException { executedFlag = true; } public void shutdown(){} }, "0", false, new ZooKeeperServerListener(){ @Override public void notifyStopping(String errMsg, int exitCode) { }}); }