spotless

Author: SylvainJuge

jmx-scraper/src/integrationTest/java/io/opentelemetry/contrib/jmxscraper/target_systems/ActiveMqIntegrationTest.java

@@ -23,9 +23,7 @@ protected GenericContainer<?> createTargetContainer(int jmxPort) {
             new ImageFromDockerfile()
                 .withDockerfileFromBuilder(
                     builder -> builder.from("apache/activemq-classic:5.18.6").build()))
-        .withEnv(
-            "JAVA_TOOL_OPTIONS",
-            genericJmxJvmArguments(jmxPort))
+        .withEnv("JAVA_TOOL_OPTIONS", genericJmxJvmArguments(jmxPort))
         .withStartupTimeout(Duration.ofMinutes(2))
         .waitingFor(Wait.forListeningPort());
   }

jmx-scraper/src/integrationTest/java/io/opentelemetry/contrib/jmxscraper/target_systems/CassandraIntegrationTest.java

@@ -24,10 +24,11 @@ public class CassandraIntegrationTest extends TargetSystemIntegrationTest {
   @Override
   protected GenericContainer<?> createTargetContainer(int jmxPort) {
     return new GenericContainer<>("cassandra:5.0.2")
-        .withEnv("JVM_EXTRA_OPTS",
+        .withEnv(
+            "JVM_EXTRA_OPTS",
             genericJmxJvmArguments(jmxPort)
-            // making cassandra startup faster for single node, from ~1min to ~15s
-            + " -Dcassandra.skip_wait_for_gossip_to_settle=0 -Dcassandra.initial_token=0")
+                // making cassandra startup faster for single node, from ~1min to ~15s
+                + " -Dcassandra.skip_wait_for_gossip_to_settle=0 -Dcassandra.initial_token=0")
         .withStartupTimeout(Duration.ofMinutes(2))
         .waitingFor(Wait.forLogMessage(".*Startup complete.*", 1));
   }

jmx-scraper/src/integrationTest/java/io/opentelemetry/contrib/jmxscraper/target_systems/JettyIntegrationTest.java

@@ -75,14 +75,14 @@ protected void verifyMetrics() {
                 "s",
                 attrs -> attrs.containsKey("resource")),
         metric ->
-            assertSumWithAttributesMultiplePoints(metric,
+            assertSumWithAttributesMultiplePoints(
+                metric,
                 "jetty.select.count",
                 "The number of select calls.",
                 "{operations}",
                 /* isMonotonic= */ true,
                 // minor divergence from jetty.groovy with extra metrics attributes
-                attrs -> attrs.containsKey("context").containsKey("id")
-            ),
+                attrs -> attrs.containsKey("context").containsKey("id")),
         metric ->
             assertGaugeWithAttributes(
                 metric,
@@ -96,7 +96,6 @@ protected void verifyMetrics() {
                 metric,
                 "jetty.thread.queue.count",
                 "The current number of threads in the queue.",
-                "{threads}"
-            ));
+                "{threads}"));
   }
 }

jmx-scraper/src/integrationTest/java/io/opentelemetry/contrib/jmxscraper/target_systems/MetricAssertions.java

@@ -161,11 +161,14 @@ private static void assertAttributedMultiplePoints(
 
     points.stream()
         .map(NumberDataPoint::getAttributesList)
-        .forEach(kvList -> {
-          Map<String, String> kvMap = kvList.stream()
-              .collect(Collectors.toMap(KeyValue::getKey, kv -> kv.getValue().getStringValue()));
-          Arrays.stream(attributeGroupAssertions)
-              .forEach(assertion -> assertion.accept(assertThat(kvMap)));
-        });
+        .forEach(
+            kvList -> {
+              Map<String, String> kvMap =
+                  kvList.stream()
+                      .collect(
+                          Collectors.toMap(KeyValue::getKey, kv -> kv.getValue().getStringValue()));
+              Arrays.stream(attributeGroupAssertions)
+                  .forEach(assertion -> assertion.accept(assertThat(kvMap)));
+            });
   }
 }