parent
2c619232b3
commit
3ec97c1bb9
|
@ -55,8 +55,8 @@ public class SpringIntegrationMetricReader implements MetricReader {
|
||||||
String prefix = "integration.channel." + name;
|
String prefix = "integration.channel." + name;
|
||||||
metrics.addAll(getStatistics(prefix + ".errorRate",
|
metrics.addAll(getStatistics(prefix + ".errorRate",
|
||||||
exporter.getChannelErrorRate(name)));
|
exporter.getChannelErrorRate(name)));
|
||||||
metrics.add(new Metric<Integer>(prefix + ".sendCount", exporter
|
metrics.add(new Metric<Long>(prefix + ".sendCount", exporter
|
||||||
.getChannelSendCount(name)));
|
.getChannelSendCountLong(name)));
|
||||||
metrics.addAll(getStatistics(prefix + ".sendRate",
|
metrics.addAll(getStatistics(prefix + ".sendRate",
|
||||||
exporter.getChannelSendRate(name)));
|
exporter.getChannelSendRate(name)));
|
||||||
metrics.add(new Metric<Long>(prefix + ".receiveCount", exporter
|
metrics.add(new Metric<Long>(prefix + ".receiveCount", exporter
|
||||||
|
@ -66,8 +66,8 @@ public class SpringIntegrationMetricReader implements MetricReader {
|
||||||
metrics.addAll(getStatistics("integration.handler." + name + ".duration",
|
metrics.addAll(getStatistics("integration.handler." + name + ".duration",
|
||||||
exporter.getHandlerDuration(name)));
|
exporter.getHandlerDuration(name)));
|
||||||
}
|
}
|
||||||
metrics.add(new Metric<Long>("integration.activeHandlerCount", exporter
|
metrics.add(new Metric<Integer>("integration.activeHandlerCount", exporter
|
||||||
.getActiveHandlerCountLong()));
|
.getActiveHandlerCount()));
|
||||||
metrics.add(new Metric<Integer>("integration.handlerCount", exporter
|
metrics.add(new Metric<Integer>("integration.handlerCount", exporter
|
||||||
.getHandlerCount()));
|
.getHandlerCount()));
|
||||||
metrics.add(new Metric<Integer>("integration.channelCount", exporter
|
metrics.add(new Metric<Integer>("integration.channelCount", exporter
|
||||||
|
|
Loading…
Reference in New Issue