@Test public void testNoReportHost() { ReportClient client = new ReportClient(nodeInfo, httpClient, new ReportClientConfig().setPulseIncludeHostTag(false), new ReportTagConfig() .setTags(ImmutableMap.of("foo", "ba:r", "baz", "quux")), objectMapper); client.report(TEST_TIME, collectedData); assertEquals(sentJson.size(), 2); for (Map<String, Object> map : sentJson) { assertEquals(map.keySet(), ImmutableSet.of("name", "timestamp", "value", "tags")); Map<String, String> tags = (Map<String, String>) map.get("tags"); assertEquals(tags.get("foo"), "ba:r"); assertEquals(tags.get("baz"), "quux"); } Map<String, String> tags = (Map<String, String>) sentJson.get(0).get("tags"); assertEquals(tags.keySet(), ImmutableSet.of("application", "environment", "pool", "foo", "baz", "tag1")); tags = (Map<String, String>) sentJson.get(1).get("tags"); assertEquals(tags.keySet(), ImmutableSet.of("application", "environment", "pool", "foo", "baz")); }
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);  }