(ignite) branch master updated: IGNITE-27333 Use MessageSerializer for TcpDiscoveryClientAckResponse (#12580)

[sergeychugunov]

This is an automated email from the ASF dual-hosted git repository.

sergeychugunov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 81403902161 IGNITE-27333 Use MessageSerializer for 
TcpDiscoveryClientAckResponse (#12580)
81403902161 is described below

commit 81403902161a1d0732c3dcda3fb4b6db2b06ab4e
Author: Dmitry Werner <grimekil...@gmail.com>
AuthorDate: Thu Jan 22 12:22:06 2026 +0500

    IGNITE-27333 Use MessageSerializer for TcpDiscoveryClientAckResponse 
(#12580)
---
 .../discovery/DiscoveryMessageFactory.java         |  3 +++
 .../messages/TcpDiscoveryClientAckResponse.java    | 24 ++++++++++++++++++++--
 2 files changed, 25 insertions(+), 2 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java
index a1c3c9d9f76..a31dbf77d13 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java
@@ -22,6 +22,7 @@ import 
org.apache.ignite.internal.codegen.InetSocketAddressMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryAuthFailedMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryCacheMetricsMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryCheckFailedMessageSerializer;
+import 
org.apache.ignite.internal.codegen.TcpDiscoveryClientAckResponseSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryClientMetricsUpdateMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryClientNodesMetricsMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryClientPingRequestSerializer;
@@ -45,6 +46,7 @@ import 
org.apache.ignite.spi.discovery.tcp.messages.InetSocketAddressMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAuthFailedMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCacheMetricsMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCheckFailedMessage;
+import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientAckResponse;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientMetricsUpdateMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientNodesMetricsMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryClientPingRequest;
@@ -89,5 +91,6 @@ public class DiscoveryMessageFactory implements 
MessageFactoryProvider {
         factory.register((short)12, TcpDiscoveryDuplicateIdMessage::new, new 
TcpDiscoveryDuplicateIdMessageSerializer());
         factory.register((short)13, 
TcpDiscoveryClientMetricsUpdateMessage::new, new 
TcpDiscoveryClientMetricsUpdateMessageSerializer());
         factory.register((short)14, TcpDiscoveryMetricsUpdateMessage::new, new 
TcpDiscoveryMetricsUpdateMessageSerializer());
+        factory.register((short)15, TcpDiscoveryClientAckResponse::new, new 
TcpDiscoveryClientAckResponseSerializer());
     }
 }
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryClientAckResponse.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryClientAckResponse.java
index aa3513d33c3..1711343d779 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryClientAckResponse.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryClientAckResponse.java
@@ -18,18 +18,26 @@
 package org.apache.ignite.spi.discovery.tcp.messages;
 
 import java.util.UUID;
+import org.apache.ignite.internal.Order;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.lang.IgniteUuid;
+import org.apache.ignite.plugin.extensions.communication.Message;
 
 /**
  *
  */
-public class TcpDiscoveryClientAckResponse extends TcpDiscoveryAbstractMessage 
{
+public class TcpDiscoveryClientAckResponse extends TcpDiscoveryAbstractMessage 
implements Message {
     /** */
     private static final long serialVersionUID = 0L;
 
     /** */
-    private final IgniteUuid msgId;
+    @Order(value = 5, method = "messageId")
+    private IgniteUuid msgId;
+
+    /** */
+    public TcpDiscoveryClientAckResponse() {
+        // No-op.
+    }
 
     /**
      * @param creatorNodeId Creator node ID.
@@ -48,6 +56,13 @@ public class TcpDiscoveryClientAckResponse extends 
TcpDiscoveryAbstractMessage {
         return msgId;
     }
 
+    /**
+     * @param msgId Acknowledged message ID.
+     */
+    public void messageId(IgniteUuid msgId) {
+        this.msgId = msgId;
+    }
+
     /** {@inheritDoc} */
     @Override public boolean traceLogLevel() {
         return true;
@@ -62,4 +77,9 @@ public class TcpDiscoveryClientAckResponse extends 
TcpDiscoveryAbstractMessage {
     @Override public String toString() {
         return S.toString(TcpDiscoveryClientAckResponse.class, this, "super", 
super.toString());
     }
+
+    /** {@inheritDoc} */
+    @Override public short directType() {
+        return 15;
+    }
 }