@Test
public void testDoPipeSuccess() throws Exception {

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