Aeron upgrade to 1.49.0 and agrona to 2.3.0 (#556)

Author: lucianoviana

artio-codecs/src/main/java/uk/co/real_logic/artio/ilink/ILinkMessageConsumer.java

@@ -41,7 +41,11 @@ public interface ILinkMessageConsumer extends FixPMessageConsumer
      */
     void onBusinessMessage(FixPMessageDecoder iLinkMessage, DirectBuffer buffer, int offset, ArtioLogHeader header);
 
-    default void onMessage(FixPMessageDecoder fixPMessage, DirectBuffer buffer, int offset, ArtioLogHeader header)
+    default void onMessage(
+        final FixPMessageDecoder fixPMessage,
+        final DirectBuffer buffer,
+        final int offset,
+        final ArtioLogHeader header)
     {
         onBusinessMessage(fixPMessage, buffer, offset, header);
     }

artio-codecs/src/main/java/uk/co/real_logic/artio/util/AsciiBuffer.java

@@ -76,9 +76,9 @@ DecimalFloat getFloat(
         DecimalFloatOverflowHandler decimalFloatOverflowHandler);
 
     default DecimalFloat getFloat(
-        DecimalFloat number,
-        int offset,
-        int length)
+        final DecimalFloat number,
+        final int offset,
+        final int length)
     {
         return getFloat(number, offset, length, -1, null);
     }

artio-core/src/main/java/uk/co/real_logic/artio/engine/EngineScheduler.java

@@ -65,7 +65,7 @@ static void fail()
         throw new IllegalStateException("Cannot re-use scheduler for multiple launch attempts");
     }
 
-    static void awaitRunnerStart(AgentRunner runner)
+    static void awaitRunnerStart(final AgentRunner runner)
     {
         if (runner != null)
         {

artio-core/src/main/java/uk/co/real_logic/artio/session/ResendRequestController.java

@@ -53,7 +53,7 @@ void onResend(
      * @param remainingReplaysInFlight the number of remaining replays in flight for this Session after the completion of this
      *                        replay.
      */
-    default void onResendComplete(Session session, final int remainingReplaysInFlight)
+    default void onResendComplete(final Session session, final int remainingReplaysInFlight)
     {
         // default and empty for backwards compatibility reasons.
     }

artio-core/src/main/java/uk/co/real_logic/artio/session/SessionCustomisationStrategy.java

@@ -55,7 +55,7 @@ static SessionCustomisationStrategy none()
      * @param header the header about to be sent
      * @param sessionId the surrogate id for the Session that is being customised
      */
-    default void configureHeader(SessionHeaderEncoder header, long sessionId)
+    default void configureHeader(final SessionHeaderEncoder header, final long sessionId)
     {
     }
 }

artio-core/src/main/java/uk/co/real_logic/artio/timing/HistogramLogReader.java

@@ -21,7 +21,7 @@
 import org.agrona.LangUtil;
 import org.agrona.collections.Int2ObjectHashMap;
 import org.agrona.concurrent.BackoffIdleStrategy;
-import org.agrona.concurrent.SigInt;
+import org.agrona.concurrent.ShutdownSignalBarrier;
 import uk.co.real_logic.artio.engine.ByteBufferUtil;
 
 import java.io.File;
@@ -59,9 +59,9 @@ public static void main(final String[] args) throws IOException
             MINUTES.toNanos(1));
 
         final AtomicBoolean running = new AtomicBoolean(true);
-        SigInt.register(() -> running.set(false));
 
-        try (HistogramLogReader logReader = new HistogramLogReader(file))
+        try (ShutdownSignalBarrier barrier = new ShutdownSignalBarrier(() -> running.set(false));
+            HistogramLogReader logReader = new HistogramLogReader(file))
         {
             do
             {

artio-core/src/main/java/uk/co/real_logic/artio/validation/AuthenticationStrategy.java

@@ -50,7 +50,7 @@ static AuthenticationStrategy of(final MessageValidationStrategy delegate)
      *              message and is safe to use within your own code without copying.
      * @param authProxy the proxy to notify when you're ready to authenticate.
      */
-    default void authenticateAsync(AbstractLogonDecoder logon, AuthenticationProxy authProxy)
+    default void authenticateAsync(final AbstractLogonDecoder logon, final AuthenticationProxy authProxy)
     {
         if (authenticate(logon))
         {

artio-samples/src/main/java/uk/co/real_logic/artio/SampleUtil.java

@@ -18,7 +18,7 @@
 import io.aeron.driver.MediaDriver;
 import org.agrona.concurrent.Agent;
 import org.agrona.concurrent.AgentRunner;
-import org.agrona.concurrent.SigInt;
+import org.agrona.concurrent.ShutdownSignalBarrier;
 import org.agrona.concurrent.status.AtomicCounter;
 import uk.co.real_logic.artio.library.FixLibrary;
 import uk.co.real_logic.artio.library.LibraryConfiguration;
@@ -52,13 +52,14 @@ public static void runAgentUntilSignal(
         final Thread thread = AgentRunner.startOnThread(runner);
 
         final AtomicBoolean running = new AtomicBoolean(true);
-        SigInt.register(() -> running.set(false));
-
-        while (running.get())
+        try (ShutdownSignalBarrier barrier = new ShutdownSignalBarrier(() -> running.set(false)))
         {
-            Thread.sleep(100);
-        }
+            while (running.get())
+            {
+                Thread.sleep(100);
+            }
 
-        thread.join();
+            thread.join();
+        }
     }
 }

artio-samples/src/main/java/uk/co/real_logic/artio/server/SampleServer.java

@@ -21,7 +21,7 @@
 import io.aeron.driver.MediaDriver.Context;
 import org.agrona.IoUtil;
 import org.agrona.concurrent.IdleStrategy;
-import org.agrona.concurrent.SigInt;
+import org.agrona.concurrent.ShutdownSignalBarrier;
 import uk.co.real_logic.artio.CommonConfiguration;
 import uk.co.real_logic.artio.SampleUtil;
 import uk.co.real_logic.artio.engine.EngineConfiguration;
@@ -96,17 +96,20 @@ public static void main(final String[] args)
             try (FixLibrary library = SampleUtil.blockingConnect(libraryConfiguration))
             {
                 final AtomicBoolean running = new AtomicBoolean(true);
-                SigInt.register(() -> running.set(false));
-
-                while (running.get())
+                try (ShutdownSignalBarrier barrier = new ShutdownSignalBarrier(() -> running.set(false)))
                 {
-                    idleStrategy.idle(library.poll(1));
 
-                    if (session != null && session.state() == DISCONNECTED)
+                    while (running.get())
                     {
-                        break;
+                        idleStrategy.idle(library.poll(1));
+
+                        if (session != null && session.state() == DISCONNECTED)
+                        {
+                            break;
+                        }
                     }
                 }
+
             }
         }
 

gradle/libs.versions.toml

@@ -1,8 +1,8 @@
 [versions]
-aeron = "1.48.5"
-agrona = "2.2.4"
-byteBuddy = "1.17.6"
-checkstyle = "10.26.0"
+aeron = "1.49.0"
+agrona = "2.3.0"
+byteBuddy = "1.17.7"
+checkstyle = "11.1.0"
 commons-codec = "1.15"
 commons-lang3 = "3.8.1"
 hamcrest = "3.0"
@@ -12,11 +12,11 @@ jmh = "1.37"
 json = "20250517"
 junit = "5.13.2"
 junit4 = "4.13.2"
-mockito = "5.18.0"
+mockito = "5.20.0"
 plexus = "3.3.0"
-sbe = "1.35.6"
+sbe = "1.36.0"
 shadow = "8.3.7"
-versions = "0.52.0"
+versions = "0.53.0"
 
 [libraries]
 agrona = { group = "org.agrona", name = "agrona", version.ref = "agrona" }