@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); FileDataInputParameter p = new FileDataInputParameter(); p.setDestination(helper.createProduceDestination()); AdaptrisMessage msg = AdaptrisMessageFactory.getDefaultInstance().newMessage(); assertNotNull(p.extract(msg)); } finally { LifecycleHelper.stopAndClose(channel); helper.stopServer(); } }
@Override public String extract(InterlokMessage message) throws CoreException { try { return load(new URLString(url(message)), message.getContentEncoding()); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } }
FileDataInputParameter extends FileParameter implements DataInputParameter<String> { @Override public String extract(InterlokMessage message) throws CoreException { try { return load(new URLString(url(message)), message.getContentEncoding()); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } } }
FileDataInputParameter extends FileParameter implements DataInputParameter<String> { @Override public String extract(InterlokMessage message) throws CoreException { try { return load(new URLString(url(message)), message.getContentEncoding()); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } } FileDataInputParameter(); }
FileDataInputParameter extends FileParameter implements DataInputParameter<String> { @Override public String extract(InterlokMessage message) throws CoreException { try { return load(new URLString(url(message)), message.getContentEncoding()); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } } FileDataInputParameter(); @Override String extract(InterlokMessage message); }
FileDataInputParameter extends FileParameter implements DataInputParameter<String> { @Override public String extract(InterlokMessage message) throws CoreException { try { return load(new URLString(url(message)), message.getContentEncoding()); } catch (IOException ex) { throw ExceptionHelper.wrapCoreException(ex); } } FileDataInputParameter(); @Override String extract(InterlokMessage message);  }