@Test(expected = CoreException.class) public void testExtractWithException() throws Exception { PayloadStreamInputParameter p = new PayloadStreamInputParameter(); AdaptrisMessage msg = new MyDefectiveMessage(); try (InputStream in = p.extract(msg)) { } }
@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);  }