@Test public void testExtract() throws Exception { PayloadStreamInputParameter p = new PayloadStreamInputParameter(); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(TEXT.getBytes()); try (InputStream in = p.extract(msg)) { List<String> strings = IOUtils.readLines(in, Charset.defaultCharset()); assertEquals(1, strings.size()); assertEquals(TEXT, strings.get(0)); } }
@Override public InputStream extract(InterlokMessage message) throws InterlokException { InputStream result = null; try { result = message.getInputStream(); } catch (IOException e) { throw ExceptionHelper.wrapCoreException(e); } return result; }
PayloadStreamInputParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws InterlokException { InputStream result = null; try { result = message.getInputStream(); } catch (IOException e) { throw ExceptionHelper.wrapCoreException(e); } return result; } }
PayloadStreamInputParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws InterlokException { InputStream result = null; try { result = message.getInputStream(); } catch (IOException e) { throw ExceptionHelper.wrapCoreException(e); } return result; } PayloadStreamInputParameter(); }
PayloadStreamInputParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws InterlokException { InputStream result = null; try { result = message.getInputStream(); } catch (IOException e) { throw ExceptionHelper.wrapCoreException(e); } return result; } PayloadStreamInputParameter(); @Override InputStream extract(InterlokMessage message); }
PayloadStreamInputParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws InterlokException { InputStream result = null; try { result = message.getInputStream(); } catch (IOException e) { throw ExceptionHelper.wrapCoreException(e); } return result; } PayloadStreamInputParameter(); @Override InputStream extract(InterlokMessage message);  }