CounterSwitchPipe extends FixedForwardPipe { @IbisDoc({" ", "2"}) public void setDivisor(int i) { divisor = i; }  @Override void configure(); @Override PipeRunResult doPipe(Message message, IPipeLineSession session); int getDivisor(); @IbisDoc({" ", "2"}) void setDivisor(int i);  }
@Test(expected = ConfigurationException.class) public void testDivisorLessThanTwo() throws Exception { pipe.setDivisor(1); configureAndStartPipe(); }
@Test(expected = ConfigurationException.class) public void testNonExistingForward() throws Exception { pipe.setDivisor(3); configureAndStartPipe(); }