File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
src/main/java/org/graylog/outputs/metrics Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change 2626 <project .build.sourceEncoding>UTF-8</project .build.sourceEncoding>
2727 <maven .compiler.source>1.7</maven .compiler.source>
2828 <maven .compiler.target>1.7</maven .compiler.target>
29- <graylog2 .version>2.0.0 </graylog2 .version>
29+ <graylog2 .version>2.0.3 </graylog2 .version>
3030 <graylog2 .plugin-dir>/usr/share/graylog-server/plugin</graylog2 .plugin-dir>
3131 <metrics .version>3.1.2</metrics .version>
3232 <metrics .statsd.version>4.1.2</metrics .statsd.version>
Original file line number Diff line number Diff line change 3131import java .util .List ;
3232import java .util .Map ;
3333import java .util .SortedSet ;
34+ import java .util .concurrent .ConcurrentHashMap ;
3435import java .util .concurrent .TimeUnit ;
3536import java .util .concurrent .atomic .AtomicBoolean ;
3637
@@ -53,7 +54,8 @@ public class MetricsOutput implements MessageOutput {
5354 private StatsDReporter statsDReporter ;
5455
5556 private final MetricRegistry registry = new MetricRegistry ();
56- private AtomicLongMap <String > metricBuffer = AtomicLongMap .create ();
57+ // private AtomicLongMap<String> metricBuffer = AtomicLongMap.create();
58+ private ConcurrentHashMap <String , Double > metricBuffer = new ConcurrentHashMap <>();
5759 private List <String > metricFields ;
5860
5961 @ Inject
@@ -143,7 +145,7 @@ public Number getValue() {
143145 });
144146 }
145147 // Update metric
146- metricBuffer .put (metricName , metricValue .longValue ());
148+ metricBuffer .put (metricName , metricValue .doubleValue ());
147149 break ;
148150 case "counter" :
149151 final Counter counter = registry .counter (metricName );
You can’t perform that action at this time.
0 commit comments