(ignite) branch master updated: IGNITE-27901 Use MessageSerializer for MetadataUpdateAcceptedMessage (#12767)

[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 69fe97019b8 IGNITE-27901 Use MessageSerializer for 
MetadataUpdateAcceptedMessage (#12767)
69fe97019b8 is described below

commit 69fe97019b8ff8dcb5886c0eaee597f4ead1d876
Author: Alexey Abashev <ale...@abashev.ru>
AuthorDate: Wed Mar 4 09:59:08 2026 +0300

    IGNITE-27901 Use MessageSerializer for MetadataUpdateAcceptedMessage 
(#12767)
---
 .../discovery/DiscoveryMessageFactory.java         |  5 +++++
 .../binary/MetadataUpdateAcceptedMessage.java      | 25 +++++++++++++++++-----
 2 files changed, 25 insertions(+), 5 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 ed1fa6e03ea..9b82ee21513 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
@@ -27,6 +27,8 @@ import 
org.apache.ignite.internal.processors.cache.binary.MetadataRemoveAccepted
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataRemoveAcceptedMessageSerializer;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataRemoveProposedMessage;
 import 
org.apache.ignite.internal.processors.cache.binary.MetadataRemoveProposedMessageSerializer;
+import 
org.apache.ignite.internal.processors.cache.binary.MetadataUpdateAcceptedMessage;
+import 
org.apache.ignite.internal.processors.cache.binary.MetadataUpdateAcceptedMessageSerializer;
 import 
org.apache.ignite.internal.processors.query.schema.message.SchemaFinishDiscoveryMessage;
 import 
org.apache.ignite.internal.processors.query.schema.message.SchemaFinishDiscoveryMessageSerializer;
 import 
org.apache.ignite.internal.processors.query.schema.message.SchemaProposeDiscoveryMessage;
@@ -145,5 +147,8 @@ public class DiscoveryMessageFactory implements 
MessageFactoryProvider {
         factory.register((short)505, SchemaFinishDiscoveryMessage::new, new 
SchemaFinishDiscoveryMessageSerializer());
         factory.register((short)506, WalStateFinishMessage::new, new 
WalStateFinishMessageSerializer());
         factory.register((short)507, WalStateProposeMessage::new, new 
WalStateProposeMessageSerializer());
+        factory.register((short)508, MetadataUpdateAcceptedMessage::new,
+            new MetadataUpdateAcceptedMessageSerializer());
+
     }
 }
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
index 0416746a04b..0edbc2e67ae 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/MetadataUpdateAcceptedMessage.java
@@ -16,12 +16,14 @@
  */
 package org.apache.ignite.internal.processors.cache.binary;
 
+import org.apache.ignite.internal.Order;
 import org.apache.ignite.internal.managers.discovery.DiscoCache;
 import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
 import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager;
 import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion;
 import org.apache.ignite.internal.util.typedef.internal.S;
 import org.apache.ignite.lang.IgniteUuid;
+import org.apache.ignite.plugin.extensions.communication.Message;
 import org.jetbrains.annotations.Nullable;
 
 /**
@@ -30,27 +32,35 @@ import org.jetbrains.annotations.Nullable;
  * As discovery messaging doesn't guarantee that message makes only one pass 
across the cluster
  * <b>MetadataUpdateAcceptedMessage</b> enables to mark it as duplicated so 
other nodes won't process it but skip.
  */
-public class MetadataUpdateAcceptedMessage implements DiscoveryCustomMessage {
+public class MetadataUpdateAcceptedMessage implements DiscoveryCustomMessage, 
Message {
     /** */
     private static final long serialVersionUID = 0L;
 
     /** */
-    private final IgniteUuid id = IgniteUuid.randomUuid();
+    @Order(0)
+    IgniteUuid id;
 
     /** */
-    private final int typeId;
+    @Order(1)
+    int typeId;
 
     /** */
-    private final int acceptedVer;
+    @Order(2)
+    int acceptedVer;
 
     /** */
-    private boolean duplicated;
+    @Order(3)
+    boolean duplicated;
+
+    /** */
+    public MetadataUpdateAcceptedMessage() {}
 
     /**
      * @param typeId Type id.
      * @param acceptedVer Accepted version.
      */
     MetadataUpdateAcceptedMessage(int typeId, int acceptedVer) {
+        id = IgniteUuid.randomUuid();
         this.typeId = typeId;
         this.acceptedVer = acceptedVer;
     }
@@ -98,6 +108,11 @@ public class MetadataUpdateAcceptedMessage implements 
DiscoveryCustomMessage {
         this.duplicated = duplicated;
     }
 
+    /** {@inheritDoc} */
+    @Override public short directType() {
+        return 508;
+    }
+
     /** {@inheritDoc} */
     @Override public String toString() {
         return S.toString(MetadataUpdateAcceptedMessage.class, this);