@Test
public void doSuccessTest() throws Exception {

	pipe.registerForward(createPipeFailureForward());
	pipe.configure();
	pipe.start();
	PipeRunResult pipeRunResult = doPipe(pipe, "{\"input\":\"ok\"}", session);
	assertEquals("success", pipeRunResult.getPipeForward().getName());
}