IGNITE-23168

* minor code style fixes (2)
apache · Nov 22, 2024 · ba41ba1 · ba41ba1
1 parent 716eefd
commit ba41ba1
Showing 1 changed file with 11 additions and 19 deletions.
diff --git a/modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java b/modules/core/src/test/java/org/apache/ignite/cdc/AbstractCdcTest.java
@@ -228,9 +228,18 @@ protected void checkMetrics(CdcMain cdc, int expCnt) throws Exception {
 
         DynamicMBean jmxCdcReg = metricRegistry(cdcInstanceName(cfg.getIgniteInstanceName()), null, "cdc");
 
-        checkMetrics(expCnt, jmxValue(jmxCdcReg), jmxValue(jmxCdcReg), jmxValue(jmxCdcReg));
+        Function<String, ?> jmxVal = m -> {
+            try {
+                return jmxCdcReg.getAttribute(m);
+            }
+            catch (Exception e) {
+                throw new IgniteException(e);
+            }
+        };
+
+        checkMetrics(expCnt, (Function<String, Long>)jmxVal, (Function<String, String>)jmxVal, (Function<String, long[]>)jmxVal);
 
-        MetricRegistry mreg = registry(cdc);
+        MetricRegistry mreg = getFieldValue(cdc, "mreg");
 
         assertNotNull(mreg);
 
@@ -272,23 +281,6 @@ private void checkMetrics(
         assertTrue(Arrays.stream(longArrMetric.apply(EVENTS_CONSUMPTION_TIME)).sum() > 0);
     }
 
-    /** @return {@link MetricRegistry} */
-    private MetricRegistry registry(CdcMain cdc) {
-        return getFieldValue(cdc, "mreg");
-    }
-
-    /** */
-    private <T> Function<String, T> jmxValue(DynamicMBean jmxCdcReg) {
-        return m -> {
-            try {
-                return (T)jmxCdcReg.getAttribute(m);
-            }
-            catch (Exception e) {
-                throw new IgniteException(e);
-            }
-        };
-    }
-
     /** */
     protected boolean keepBinary() {
         return false;