@Test public void testReportingDisabled() { httpClient = new TestingHttpClient(); ReportClient client = new ReportClient(nodeInfo, httpClient, new ReportClientConfig().setEnabled(false), new ReportTagConfig(), objectMapper); client.report(System.currentTimeMillis(), collectedData); }
public void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData) { Request request = preparePost() .setUri(UPLOAD_URI) .setHeader("Content-Type", "application/gzip") .setBodySource(new CompressBodySource(systemTimeMillis, collectedData)) .build(); try { StringResponse response = httpClient.execute(request, createStringResponseHandler()); if (response.getStatusCode() != 204) { logger.warn("Failed to report stats: %s %s %s", response.getStatusCode(), response.getStatusMessage(), response.getBody()); } } catch (RuntimeException e) { logger.warn(e, "Exception when trying to report stats"); } }
ReportClient { public void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData) { Request request = preparePost() .setUri(UPLOAD_URI) .setHeader("Content-Type", "application/gzip") .setBodySource(new CompressBodySource(systemTimeMillis, collectedData)) .build(); try { StringResponse response = httpClient.execute(request, createStringResponseHandler()); if (response.getStatusCode() != 204) { logger.warn("Failed to report stats: %s %s %s", response.getStatusCode(), response.getStatusMessage(), response.getBody()); } } catch (RuntimeException e) { logger.warn(e, "Exception when trying to report stats"); } } }
ReportClient { public void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData) { Request request = preparePost() .setUri(UPLOAD_URI) .setHeader("Content-Type", "application/gzip") .setBodySource(new CompressBodySource(systemTimeMillis, collectedData)) .build(); try { StringResponse response = httpClient.execute(request, createStringResponseHandler()); if (response.getStatusCode() != 204) { logger.warn("Failed to report stats: %s %s %s", response.getStatusCode(), response.getStatusMessage(), response.getBody()); } } catch (RuntimeException e) { logger.warn(e, "Exception when trying to report stats"); } } @Inject  ReportClient(NodeInfo nodeInfo, @ForReportClient HttpClient httpClient, ReportClientConfig reportClientConfig, ReportTagConfig reportTagConfig, ObjectMapper objectMapper); }
ReportClient { public void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData) { Request request = preparePost() .setUri(UPLOAD_URI) .setHeader("Content-Type", "application/gzip") .setBodySource(new CompressBodySource(systemTimeMillis, collectedData)) .build(); try { StringResponse response = httpClient.execute(request, createStringResponseHandler()); if (response.getStatusCode() != 204) { logger.warn("Failed to report stats: %s %s %s", response.getStatusCode(), response.getStatusMessage(), response.getBody()); } } catch (RuntimeException e) { logger.warn(e, "Exception when trying to report stats"); } } @Inject  ReportClient(NodeInfo nodeInfo, @ForReportClient HttpClient httpClient, ReportClientConfig reportClientConfig, ReportTagConfig reportTagConfig, ObjectMapper objectMapper); void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData); }
ReportClient { public void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData) { Request request = preparePost() .setUri(UPLOAD_URI) .setHeader("Content-Type", "application/gzip") .setBodySource(new CompressBodySource(systemTimeMillis, collectedData)) .build(); try { StringResponse response = httpClient.execute(request, createStringResponseHandler()); if (response.getStatusCode() != 204) { logger.warn("Failed to report stats: %s %s %s", response.getStatusCode(), response.getStatusMessage(), response.getBody()); } } catch (RuntimeException e) { logger.warn(e, "Exception when trying to report stats"); } } @Inject  ReportClient(NodeInfo nodeInfo, @ForReportClient HttpClient httpClient, ReportClientConfig reportClientConfig, ReportTagConfig reportTagConfig, ObjectMapper objectMapper); void report(long systemTimeMillis, Table<String, Map<String, String>, Object> collectedData);  }