EchoPipe extends FixedForwardPipe { @Override public PipeRunResult doPipe(Message message, IPipeLineSession session) { return new PipeRunResult(getForward(),message); }  @Override PipeRunResult doPipe(Message message, IPipeLineSession session);  }
@Test public void testDoPipe() throws PipeRunException, IOException { String dummyInput = "dummyInput"; PipeRunResult prr = doPipe(pipe, dummyInput, session); String result = Message.asString(prr.getResult()); assertEquals(dummyInput, result); }