(ignite) branch master updated: IGNITE-27614 Use MessageSerializer for TcpDiscoveryNodeFailedMessage (#12646)

[shishkovilja]

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

shishkovilja 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 78ead92df22 IGNITE-27614 Use MessageSerializer for 
TcpDiscoveryNodeFailedMessage (#12646)
78ead92df22 is described below

commit 78ead92df22d3379df73956142da23a48a4012d2
Author: Dmitry Werner <grimekil...@gmail.com>
AuthorDate: Mon Feb 2 22:45:12 2026 +0500

    IGNITE-27614 Use MessageSerializer for TcpDiscoveryNodeFailedMessage 
(#12646)
---
 .../discovery/DiscoveryMessageFactory.java         |  3 ++
 .../messages/TcpDiscoveryNodeFailedMessage.java    | 35 ++++++++++++++++++++--
 2 files changed, 35 insertions(+), 3 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 c1421ae064f..06cdf3e25d3 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
@@ -34,6 +34,7 @@ import 
org.apache.ignite.internal.codegen.TcpDiscoveryHandshakeRequestSerializer
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryHandshakeResponseSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryLoopbackProblemMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryMetricsUpdateMessageSerializer;
+import 
org.apache.ignite.internal.codegen.TcpDiscoveryNodeFailedMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryNodeFullMetricsMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryNodeLeftMessageSerializer;
 import 
org.apache.ignite.internal.codegen.TcpDiscoveryNodeMetricsMessageSerializer;
@@ -59,6 +60,7 @@ import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryHandshakeRequest
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryHandshakeResponse;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryLoopbackProblemMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryMetricsUpdateMessage;
+import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeFailedMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeFullMetricsMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeLeftMessage;
 import 
org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryNodeMetricsMessage;
@@ -95,5 +97,6 @@ public class DiscoveryMessageFactory implements 
MessageFactoryProvider {
         factory.register((short)14, TcpDiscoveryMetricsUpdateMessage::new, new 
TcpDiscoveryMetricsUpdateMessageSerializer());
         factory.register((short)15, TcpDiscoveryClientAckResponse::new, new 
TcpDiscoveryClientAckResponseSerializer());
         factory.register((short)16, TcpDiscoveryNodeLeftMessage::new, new 
TcpDiscoveryNodeLeftMessageSerializer());
+        factory.register((short)17, TcpDiscoveryNodeFailedMessage::new, new 
TcpDiscoveryNodeFailedMessageSerializer());
     }
 }
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryNodeFailedMessage.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryNodeFailedMessage.java
index 2143c711171..e1dbb975b64 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryNodeFailedMessage.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryNodeFailedMessage.java
@@ -18,7 +18,9 @@
 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.plugin.extensions.communication.Message;
 import org.jetbrains.annotations.Nullable;
 
 /**
@@ -27,19 +29,27 @@ import org.jetbrains.annotations.Nullable;
  */
 @TcpDiscoveryEnsureDelivery
 @TcpDiscoveryRedirectToClient
-public class TcpDiscoveryNodeFailedMessage extends 
TcpDiscoveryAbstractTraceableMessage {
+public class TcpDiscoveryNodeFailedMessage extends 
TcpDiscoveryAbstractTraceableMessage implements Message {
     /** */
     private static final long serialVersionUID = 0L;
 
     /** ID of the failed node. */
-    private final UUID failedNodeId;
+    @Order(6)
+    private UUID failedNodeId;
 
     /** Internal order of the failed node. */
-    private final long order;
+    @Order(value = 7, method = "internalOrder")
+    private long order;
 
     /** */
+    @Order(8)
     private String warning;
 
+    /** Constructor. */
+    public TcpDiscoveryNodeFailedMessage() {
+        // No-op.
+    }
+
     /**
      * Constructor.
      *
@@ -80,6 +90,13 @@ public class TcpDiscoveryNodeFailedMessage extends 
TcpDiscoveryAbstractTraceable
         return failedNodeId;
     }
 
+    /**
+     * @param failedNodeId ID of the failed node.
+     */
+    public void failedNodeId(UUID failedNodeId) {
+        this.failedNodeId = failedNodeId;
+    }
+
     /**
      * @return Internal order of the failed node.
      */
@@ -87,8 +104,20 @@ public class TcpDiscoveryNodeFailedMessage extends 
TcpDiscoveryAbstractTraceable
         return order;
     }
 
+    /**
+     * @param order Internal order of the failed node.
+     */
+    public void internalOrder(long order) {
+        this.order = order;
+    }
+
     /** {@inheritDoc} */
     @Override public String toString() {
         return S.toString(TcpDiscoveryNodeFailedMessage.class, this, "super", 
super.toString());
     }
+
+    /** {@inheritDoc} */
+    @Override public short directType() {
+        return 17;
+    }
 }