SimpleStagingService implements StagingService { @Override public void submitStaging(Staging staging) throws IOException { executorService.execute(staging); } SimpleStagingService(File stagingDir, int numParallelJobs); @Override File getStagingDir(); @Override void submitStaging(Staging staging); @Override void deleteTree(String path); @Override void close(); @Override void setProductionService(Observable productionService); @Override Observable getProductionService();  }
@Test public void testSubmitStaging() throws IOException { SimpleStagingService stagingService = new SimpleStagingService(new File("/foo/bar/buz"), 1); Staging staging = new Staging() { @Override public void run() { } }; stagingService.submitStaging(staging); }