Java 类org.apache.zookeeper.server.RequestProcessor.RequestProcessorException 实例源码

项目:SecureKeeper    文件:CommitProcessorConcurrencyTest.java   
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) {

      }});
}
项目:SecureKeeper    文件:CommitProcessorConcurrencyTest.java   
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) {

      }});
}