(ignite) branch master updated: IGNITE-28028 Use MessageSerializer for TxTimeoutOnPartitionMapExchangeChangeMessage (#12835)

[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 e414a725df5 IGNITE-28028 Use MessageSerializer for 
TxTimeoutOnPartitionMapExchangeChangeMessage (#12835)
e414a725df5 is described below

commit e414a725df54f88a7f8402177fbb567a764bba8c
Author: Aleksandr Chesnokov <chesnokoff...@gmail.com>
AuthorDate: Wed Mar 4 15:13:15 2026 +0300

    IGNITE-28028 Use MessageSerializer for 
TxTimeoutOnPartitionMapExchangeChangeMessage (#12835)
---
 .../discovery/DiscoveryMessageFactory.java         |  5 ++-
 ...TimeoutOnPartitionMapExchangeChangeMessage.java | 36 ++++++++++++++++------
 2 files changed, 31 insertions(+), 10 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 9b82ee21513..009905b70d5 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
@@ -19,6 +19,8 @@ package org.apache.ignite.internal.managers.discovery;
 
 import 
org.apache.ignite.internal.processors.cache.CacheStatisticsModeChangeMessage;
 import 
org.apache.ignite.internal.processors.cache.CacheStatisticsModeChangeMessageSerializer;
+import 
org.apache.ignite.internal.processors.cache.TxTimeoutOnPartitionMapExchangeChangeMessage;
+import 
org.apache.ignite.internal.processors.cache.TxTimeoutOnPartitionMapExchangeChangeMessageSerializer;
 import org.apache.ignite.internal.processors.cache.WalStateFinishMessage;
 import 
org.apache.ignite.internal.processors.cache.WalStateFinishMessageSerializer;
 import org.apache.ignite.internal.processors.cache.WalStateProposeMessage;
@@ -149,6 +151,7 @@ public class DiscoveryMessageFactory implements 
MessageFactoryProvider {
         factory.register((short)507, WalStateProposeMessage::new, new 
WalStateProposeMessageSerializer());
         factory.register((short)508, MetadataUpdateAcceptedMessage::new,
             new MetadataUpdateAcceptedMessageSerializer());
-
+        factory.register((short)509, 
TxTimeoutOnPartitionMapExchangeChangeMessage::new,
+            new TxTimeoutOnPartitionMapExchangeChangeMessageSerializer());
     }
 }
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
index 6742a88a39f..a36c5f30f1c 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/TxTimeoutOnPartitionMapExchangeChangeMessage.java
@@ -18,32 +18,43 @@
 package org.apache.ignite.internal.processors.cache;
 
 import java.util.UUID;
+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;
 
 /**
  * Discovery message for changing transaction timeout on partition map 
exchange.
  */
-public class TxTimeoutOnPartitionMapExchangeChangeMessage implements 
DiscoveryCustomMessage {
+public class TxTimeoutOnPartitionMapExchangeChangeMessage implements 
DiscoveryCustomMessage, Message {
     /** */
     private static final long serialVersionUID = 0L;
 
     /** */
-    private final IgniteUuid id = IgniteUuid.randomUuid();
+    @Order(0)
+    IgniteUuid id;
 
     /** Request ID. */
-    private final UUID reqId;
+    @Order(1)
+    UUID reqId;
 
     /** Transaction timeout on partition map exchange in milliseconds. */
-    private final long timeout;
+    @Order(2)
+    long timeout;
 
     /** Init flag. */
-    private final boolean isInit;
+    @Order(3)
+    boolean isInit;
+
+    /** */
+    public TxTimeoutOnPartitionMapExchangeChangeMessage() {
+        // No-op.
+    }
 
     /**
      * Constructor for response.
@@ -51,9 +62,10 @@ public class TxTimeoutOnPartitionMapExchangeChangeMessage 
implements DiscoveryCu
      * @param req Request message.
      */
     public 
TxTimeoutOnPartitionMapExchangeChangeMessage(TxTimeoutOnPartitionMapExchangeChangeMessage
 req) {
-        this.reqId = req.reqId;
-        this.timeout = req.timeout;
-        this.isInit = false;
+        id = IgniteUuid.randomUuid();
+        reqId = req.reqId;
+        timeout = req.timeout;
+        isInit = false;
     }
 
     /**
@@ -63,9 +75,10 @@ public class TxTimeoutOnPartitionMapExchangeChangeMessage 
implements DiscoveryCu
      * @param timeout Transaction timeout on partition map exchange in 
milliseconds.
      */
     public TxTimeoutOnPartitionMapExchangeChangeMessage(UUID reqId, long 
timeout) {
+        id = IgniteUuid.randomUuid();
         this.reqId = reqId;
         this.timeout = timeout;
-        this.isInit = true;
+        isInit = true;
     }
 
     /** {@inheritDoc} */
@@ -120,4 +133,9 @@ public class TxTimeoutOnPartitionMapExchangeChangeMessage 
implements DiscoveryCu
     @Override public String toString() {
         return S.toString(TxTimeoutOnPartitionMapExchangeChangeMessage.class, 
this);
     }
+
+    /** {@inheritDoc} */
+    @Override public short directType() {
+        return 509;
+    }
 }