Jmx Reporter

utils/metrics/src/main/java/com/ea/orbit/metrics/MetricsManager.java

@@ -37,7 +37,7 @@
 
 import com.codahale.metrics.Gauge;
 import com.codahale.metrics.MetricRegistry;
-import com.codahale.metrics.ScheduledReporter;
+import com.codahale.metrics.Reporter;
 
 import java.lang.reflect.Field;
 import java.lang.reflect.InvocationTargetException;
@@ -53,20 +53,16 @@ public class MetricsManager
     private static MetricsManager instance = new MetricsManager();
     private static final MetricRegistry registry = new MetricRegistry();
     private static final Logger logger = LoggerFactory.getLogger(MetricsManager.class);
-    private Map<ReporterConfig, ScheduledReporter> reporters = new HashMap<>();
+    private Map<ReporterConfig, Reporter> reporters = new HashMap<>();
     private boolean isInitialized = false;
 
     protected MetricsManager()
     {
 
     }
 
-    public static synchronized MetricsManager getInstance()
+    public static MetricsManager getInstance()
     {
-        if (instance == null)
-        {
-            instance = new MetricsManager();
-        }
         return instance;
     }
 
@@ -82,7 +78,7 @@ public synchronized void initializeMetrics(List<ReporterConfig> reporterConfigs)
         {
             for (ReporterConfig reporterConfig : reporterConfigs)
             {
-                ScheduledReporter reporter = reporterConfig.enableReporter(registry);
+                Reporter reporter = reporterConfig.enableReporter(registry);
                 if (reporter != null)
                 {
                     reporters.put(reporterConfig, reporter);

utils/metrics/src/main/java/com/ea/orbit/metrics/config/JmxReporterConfig.java

@@ -0,0 +1,57 @@
+/*
+ Copyright (C) 2015 Electronic Arts Inc.  All rights reserved.
+
+ Redistribution and use in source and binary forms, with or without
+ modification, are permitted provided that the following conditions
+ are met:
+
+ 1.  Redistributions of source code must retain the above copyright
+     notice, this list of conditions and the following disclaimer.
+ 2.  Redistributions in binary form must reproduce the above copyright
+     notice, this list of conditions and the following disclaimer in the
+     documentation and/or other materials provided with the distribution.
+ 3.  Neither the name of Electronic Arts, Inc. ("EA") nor the names of
+     its contributors may be used to endorse or promote products derived
+     from this software without specific prior written permission.
+
+ THIS SOFTWARE IS PROVIDED BY ELECTRONIC ARTS AND ITS CONTRIBUTORS "AS IS" AND ANY
+ EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ DISCLAIMED. IN NO EVENT SHALL ELECTRONIC ARTS OR ITS CONTRIBUTORS BE LIABLE FOR ANY
+ DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+ THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package com.ea.orbit.metrics.config;
+
+import com.codahale.metrics.JmxReporter;
+import com.codahale.metrics.MetricRegistry;
+import com.codahale.metrics.Reporter;
+
+public class JmxReporterConfig extends ReporterConfig
+{
+
+    public JmxReporterConfig()
+    {
+
+    }
+
+    @Override
+    public synchronized Reporter enableReporter(MetricRegistry registry)
+    {
+        final JmxReporter reporter = JmxReporter.forRegistry(registry)
+                        .convertRatesTo(getRateTimeUnit())
+                        .convertDurationsTo(getDurationTimeUnit())
+                        .build();
+
+        reporter.start();
+
+        return reporter;
+    }
+
+
+}

utils/metrics/src/main/java/com/ea/orbit/metrics/config/ReporterConfig.java

@@ -29,7 +29,7 @@
 package com.ea.orbit.metrics.config;
 
 import com.codahale.metrics.MetricRegistry;
-import com.codahale.metrics.ScheduledReporter;
+import com.codahale.metrics.Reporter;
 
 import java.util.concurrent.TimeUnit;
 
@@ -110,5 +110,5 @@ protected TimeUnit getPeriodTimeUnit()
         return TimeUnit.valueOf(getPeriodUnit());
     }
 
-    public synchronized ScheduledReporter enableReporter(MetricRegistry registry) {return null;}
+    public synchronized Reporter enableReporter(MetricRegistry registry) {return null;}
 }