Merge pull request #48 from DataDog/yann/match-bean-issue

Buggy matchBean method fix

Author: yannmh

src/main/java/org/datadog/jmxfetch/JMXAttribute.java

@@ -207,6 +207,7 @@ Object convertMetricValue(Object metricValue) {
     }
 
     boolean matchBean(Configuration configuration) {
+        boolean matchBeanAttr = true;
         Filter include = configuration.getInclude();
 
         if (!include.isEmptyBeanName() && !include.getBeanNames().contains(beanName)) {
@@ -217,25 +218,26 @@ boolean matchBean(Configuration configuration) {
             if (EXCLUDED_BEAN_PARAMS.contains(bean_attr)) {
                 continue;
             }
+            matchBeanAttr = false;
+
             if (beanParameters.get(bean_attr) == null) {
                 continue;
             }
 
             ArrayList<String> beanValues = include.getParameterValues(bean_attr);
 
-            boolean matchBeanAttr = false;
+
             for (String beanVal : beanValues) {
                 if (!beanParameters.get(bean_attr).equals(beanVal)) {
                     continue;
                 }
                 return true;
             }
             // We havent' found a match among our attribute values list
-            if (!matchBeanAttr) {
-                return false;
-            }
+            return false;
         }
-        return true;
+        // Returns true if all bean_attr belong to EXCLUDED_BEAN_PARAMS otherwise false
+        return matchBeanAttr;
     }
 
     @SuppressWarnings("unchecked")

src/test/java/org/datadog/jmxfetch/TestApp.java

@@ -128,6 +128,29 @@ public void testDomainExclude() throws Exception {
     	mbs.unregisterMBean(excludeMe);
     }
 
+    @Test
+    public void testParameterMatch() throws Exception {
+        // Do not match beans which do not contain types specified in the conf
+        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
+        ObjectName matchParam = new ObjectName("org.datadog.jmxfetch.test:param=AParameter");
+        SimpleTestJavaApp testApp = new SimpleTestJavaApp();
+        mbs.registerMBean(testApp, matchParam);
+
+        // Initializing application
+        AppConfig appConfig = new AppConfig();
+        App app = initApp("jmx_list_params_include.yaml", appConfig);
+
+        // Collecting metrics
+        app.doIteration();
+        LinkedList<HashMap<String, Object>> metrics = ((ConsoleReporter) appConfig.getReporter()).getMetrics();
+
+        // 13 default metrics from java.lang
+        assertEquals(13, metrics.size());
+
+        mbs.unregisterMBean(matchParam);
+
+    }
+
     @Test
     public void testListParamsInclude() throws Exception {
         // We expose a few metrics through JMX