@Test public void testExtractFromRemote() throws Exception { EmbeddedJettyHelper helper = new EmbeddedJettyHelper(); helper.startServer(); MockMessageProducer mockProducer = new MockMessageProducer(); Channel channel = JettyHelper.createChannel(new EmbeddedConnection(), JettyHelper.createConsumer(URL_TO_POST_TO), mockProducer); try { LifecycleHelper.initAndStart(channel); FileInputStreamDataInputParameter p = new FileInputStreamDataInputParameter(); p.setDestination(helper.createProduceDestination()); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(); assertNotNull(p.extract(msg)); } finally { LifecycleHelper.stopAndClose(channel); helper.stopServer(); } }
@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);  }