InfluxDbReporter extends ScheduledMetrics2Reporter { private void reportMeters(Map<MetricName, Meter> meters, long timestamp) { for (Map.Entry<MetricName, Meter> entry : meters.entrySet()) { final Meter meter = entry.getValue(); reportLine(getInfluxDbLineProtocolString(entry.getKey()), reportMetered(meter), timestamp); } } private  InfluxDbReporter(Builder builder); static Builder forRegistry(Metric2Registry registry, CorePlugin corePlugin); @Override void reportMetrics(Map<MetricName, Gauge> gauges,
							  Map<MetricName, Counter> counters,
							  Map<MetricName, Histogram> histograms,
							  Map<MetricName, Meter> meters,
							  Map<MetricName, Timer> timers); static String getInfluxDbLineProtocolString(MetricName metricName);  }
@Test public void testReportMeters() throws Exception { influxDbReporter.reportMetrics( metricNameMap(Gauge.class), metricNameMap(Counter.class), metricNameMap(Histogram.class), metricNameMap(name("meter").build(), meter(10)), metricNameMap(Timer.class)); verify(httpClient).send(eq("POST"), eq("http: eq(singletonList(format("meter,app=test count=10i,m1_rate=3.0,m5_rate=4.0,m15_rate=5.0,mean_rate=2.0 %d", timestamp)))); }