SimpleFeeder implements ReplyHandler { void close() throws Exception { destination.close(); mbus.destroy(); } SimpleFeeder(FeederParams params); static void main(String[] args); @Override void handleReply(Reply reply);  }
@Test public void requireThatDynamicThrottlingIsDefault() throws Exception { TestDriver driver = new TestDriver(new FeederParams(), "", null); assertEquals(DynamicThrottlePolicy.class, getThrottlePolicy(driver).getClass()); assertTrue(driver.close()); }
@Test public void requireThatSerialTransferModeConfiguresStaticThrottling() throws Exception { TestDriver driver = new TestDriver(new FeederParams().setSerialTransfer(), "", null); assertEquals(StaticThrottlePolicy.class, getThrottlePolicy(driver).getClass()); assertTrue(driver.close()); }