@Test
public void testDoPipeFail() throws Exception {

    String myString = "testString";
    Message m = new Message(myString);
    PipeRunResult res = doPipe(pipe, m, session);
    assertEquals("testString", res.getResult().asString());
}