@Test(expected = CoreException.class) public void testNonExistingFile() throws Exception { AdaptrisMessage m = new DefaultMessageFactory().newMessage(); FileInputStreamDataInputParameter p = new FileInputStreamDataInputParameter(); try { p.url(m); fail(); } catch (IllegalArgumentException e) { } p.setDestination(new ConfiguredProduceDestination("file: assertEquals("file: InputStream result = p.extract(m); }
@Override public InputStream extract(InterlokMessage message) throws CoreException { try { return connect(new URLString(url(message))); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } }
FileInputStreamDataInputParameter extends FileParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws CoreException { try { return connect(new URLString(url(message))); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } } }
FileInputStreamDataInputParameter extends FileParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws CoreException { try { return connect(new URLString(url(message))); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } }  }
FileInputStreamDataInputParameter extends FileParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws CoreException { try { return connect(new URLString(url(message))); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } }  @Override InputStream extract(InterlokMessage message); }
FileInputStreamDataInputParameter extends FileParameter implements DataInputParameter<InputStream> { @Override public InputStream extract(InterlokMessage message) throws CoreException { try { return connect(new URLString(url(message))); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } }  @Override InputStream extract(InterlokMessage message);  }