DataConsumer { public String sendRequestSync(String path) { return getResponse(path); } DataConsumer(); DataConsumer addDataTransformer(DataTransformer dc); DataConsumer addDataWriter(DataWriter ow); DataConsumer setReportingHost(String reportingHost); DataConsumer setMaxNumberOfLines(long maxNumberOfLines); DataConsumer setExitFlag(AtomicBoolean flag); AtomicBoolean getExitFlag(); long getMaxNumberOfLines(); String getReportingHost(); DataPipe getDataPipe(); int consume(Map<String, String> initialVars); List<Map<String, String>> transformAndReturn(Map<String, String> initialVars); Future<String> sendRequest(final String path); Future<String> sendRequest(final String path, final ReportingHandler reportingHandler); String sendRequestSync(String path);  }
@Test public void testSendRequestSync() throws Exception { String reportingHost = runJetty(); DataConsumer theConsumer = new DataConsumer(); theConsumer.setReportingHost(reportingHost); String response = theConsumer.sendRequestSync("test1"); Assert.assertEquals("test1", response.trim()); }