@Test public void testExtractDestination() throws Exception { FileInputStreamDataInputParameter p = new FileInputStreamDataInputParameter(); File f = TempFileUtils.createTrackedFile(testName.getMethodName(), "", p); p.setDestination(new ConfiguredProduceDestination("file: FileUtils.write(f, TEXT, false); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(); assertNotSame(TEXT, msg.getContent()); InputStream stream = p.extract(msg); byte[] result = new byte[TEXT.length()]; stream.read(result); assertEquals(TEXT, new String(result)); }
@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);  }