Fixed build for jdk 17

Author: artem-v

metrics-examples/src/main/java/io/scalecube/metrics/loki/LokiPublisherAgent.java

@@ -14,8 +14,9 @@
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.zip.GZIPOutputStream;
-import org.agrona.CloseHelper;
 import org.agrona.LangUtil;
 import org.agrona.concurrent.Agent;
 import org.agrona.concurrent.AgentTerminationException;
@@ -45,6 +46,7 @@ public enum State {
   private final Delay retryInterval;
   private final Delay publishInterval;
   private HttpClient httpClient;
+  private ExecutorService executor;
   private CompletableFuture<HttpResponse<String>> future;
   private State state = State.CLOSED;
 
@@ -97,7 +99,14 @@ private int init() {
       return 0;
     }
 
-    httpClient = HttpClient.newHttpClient();
+    executor =
+        Executors.newSingleThreadExecutor(
+            r -> {
+              final var thread = new Thread(r);
+              thread.setDaemon(true);
+              return thread;
+            });
+    httpClient = HttpClient.newBuilder().executor(executor).build();
     publishInterval.delay();
 
     state(State.RUNNING);
@@ -157,8 +166,12 @@ public static byte[] gzip(WriteRequest request) {
   }
 
   private int cleanup() {
-    CloseHelper.quietClose(httpClient);
+    if (executor != null) {
+      executor.shutdownNow();
+    }
+    // CloseHelper.quietClose(httpClient);
     httpClient = null;
+    executor = null;
 
     if (future != null) {
       future.cancel(true);

metrics-mimir/src/main/java/io/scalecube/metrics/mimir/MimirPublisherAgent.java

@@ -9,7 +9,8 @@
 import java.net.http.HttpResponse;
 import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
-import org.agrona.CloseHelper;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import org.agrona.LangUtil;
 import org.agrona.concurrent.Agent;
 import org.agrona.concurrent.AgentTerminationException;
@@ -37,6 +38,7 @@ public enum State {
 
   private final Delay retryInterval;
   private final Delay publishInterval;
+  private ExecutorService executor;
   private HttpClient httpClient;
   private CompletableFuture<HttpResponse<String>> future;
   private State state = State.CLOSED;
@@ -90,7 +92,14 @@ private int init() {
       return 0;
     }
 
-    httpClient = HttpClient.newHttpClient();
+    executor =
+        Executors.newSingleThreadExecutor(
+            r -> {
+              final var thread = new Thread(r);
+              thread.setDaemon(true);
+              return thread;
+            });
+    httpClient = HttpClient.newBuilder().executor(executor).build();
     publishInterval.delay();
 
     state(State.RUNNING);
@@ -154,8 +163,12 @@ private CompletableFuture<HttpResponse<String>> send(WriteRequest request) {
   }
 
   private int cleanup() {
-    CloseHelper.quietClose(httpClient);
+    if (executor != null) {
+      executor.shutdownNow();
+    }
+    // CloseHelper.quietClose(httpClient);
     httpClient = null;
+    executor = null;
 
     if (future != null) {
       future.cancel(true);

pom.xml

@@ -223,4 +223,19 @@
     </dependencies>
   </dependencyManagement>
 
+  <build>
+    <plugins>
+      <plugin>
+        <artifactId>maven-surefire-plugin</artifactId>
+        <configuration>
+          <argLine>
+            -javaagent:${settings.localRepository}/org/mockito/mockito-core/${mockito.version}/mockito-core-${mockito.version}.jar
+            --add-exports java.base/jdk.internal.misc=ALL-UNNAMED
+            --add-exports java.base/sun.nio.ch=ALL-UNNAMED
+          </argLine>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+
 </project>