added handler for onEstablishmentAck()

quickfix-j · Feb 25, 2025 · b2ede48 · b2ede48
1 parent 3b89e38
commit b2ede48
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/artio-codecs/src/main/java/uk/co/real_logic/artio/fixp/FixPConnectionHandler.java b/artio-codecs/src/main/java/uk/co/real_logic/artio/fixp/FixPConnectionHandler.java
@@ -105,6 +105,14 @@ default Action onRetransmitRequest(
         return Action.CONTINUE;
     }
 
+    default Action onEstablishmentAck(
+        final FixPConnection connection, long previousUuid, long previousSeqNo, long uuid, long lastuuid,
+        long nextSeqNo)
+    {
+        // default for backwards compatibility.
+        return Action.CONTINUE;
+    }
+
     /**
      * Callback triggered by a timeout on a retransmit request. See
      * {@link Builder#retransmitNotificationTimeoutInMs(int)} for details.

diff --git a/artio-ilink3-impl/src/main/java/uk/co/real_logic/artio/library/InternalILink3Connection.java b/artio-ilink3-impl/src/main/java/uk/co/real_logic/artio/library/InternalILink3Connection.java
@@ -775,6 +775,8 @@ public Action onEstablishmentAck(
         initiateReply = null;
         nextReceiveMessageTimeInMs = nextRecvTimeoutInMs();
 
+        handler.onEstablishmentAck(this, previousUUID, previousSeqNo, uUID, lastUuid, nextSeqNo);
+
         if (previousUUID == lastUuid)
         {
             if (previousSeqNo > lastConnectionLastReceivedSequenceNumber)