IGNITE-27900 Use message serializer for CacheStatisticsClearMessage

modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java

@@ -17,6 +17,7 @@
 
 package org.apache.ignite.internal.managers.discovery;
 
+import org.apache.ignite.internal.codegen.CacheStatisticsClearMessageSerializer;
 import org.apache.ignite.internal.codegen.DiscoveryDataPacketSerializer;
 import org.apache.ignite.internal.codegen.InetAddressMessageSerializer;
 import org.apache.ignite.internal.codegen.InetSocketAddressMessageSerializer;
@@ -45,6 +46,7 @@
 import org.apache.ignite.internal.codegen.TcpDiscoveryPingResponseSerializer;
 import org.apache.ignite.internal.codegen.TcpDiscoveryRingLatencyCheckMessageSerializer;
 import org.apache.ignite.internal.codegen.TcpDiscoveryStatusCheckMessageSerializer;
+import org.apache.ignite.internal.processors.cache.CacheStatisticsClearMessage;
 import org.apache.ignite.plugin.extensions.communication.MessageFactory;
 import org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider;
 import org.apache.ignite.spi.discovery.tcp.internal.DiscoveryDataPacket;
@@ -110,5 +112,8 @@ public class DiscoveryMessageFactory implements MessageFactoryProvider {
         factory.register((short)17, TcpDiscoveryNodeFailedMessage::new, new TcpDiscoveryNodeFailedMessageSerializer());
         factory.register((short)18, TcpDiscoveryStatusCheckMessage::new, new TcpDiscoveryStatusCheckMessageSerializer());
         factory.register((short)19, TcpDiscoveryNodeAddFinishedMessage::new, new TcpDiscoveryNodeAddFinishedMessageSerializer());
+
+        factory.register(CacheStatisticsClearMessage.DIRECT_TYPE, CacheStatisticsClearMessage::new,
+            new CacheStatisticsClearMessageSerializer());
     }
 }

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheStatisticsClearMessage.java

@@ -19,18 +19,23 @@
 
 import java.util.Collection;
 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;
 
 /**
  * Cache statistics clear discovery message.
  */
-public class CacheStatisticsClearMessage implements DiscoveryCustomMessage {
+public class CacheStatisticsClearMessage implements DiscoveryCustomMessage, Message {
+    /** */
+    public static final short DIRECT_TYPE = 501;
+
     /** */
     private static final long serialVersionUID = 0L;
 
@@ -41,13 +46,23 @@ public class CacheStatisticsClearMessage implements DiscoveryCustomMessage {
     private final IgniteUuid id = IgniteUuid.randomUuid();
 
     /** Request id. */
-    private final UUID reqId;
+    @Order(value = 0, method = "requestId")
+    private UUID reqId;
 
     /** Cache names. */
-    private final Collection<String> caches;
+    @Order(1)
+    private Collection<String> caches;
 
     /** Flags. */
-    private final byte flags;
+    @Order(2)
+    private byte flags;
+
+    /**
+     * Default constructor.
+     */
+    public CacheStatisticsClearMessage() {
+        // No-op.
+    }
 
     /**
      * Constructor for request.
@@ -92,13 +107,25 @@ private CacheStatisticsClearMessage(CacheStatisticsClearMessage msg) {
         return initial() ? new CacheStatisticsClearMessage(this) : null;
     }
 
+    /** {@inheritDoc} */
+    @Override public short directType() {
+        return DIRECT_TYPE;
+    }
+
     /**
      * @return Cache names.
      */
     public Collection<String> caches() {
         return this.caches;
     }
 
+    /**
+     * @param caches Cache names.
+     */
+    public void caches(Collection<String> caches) {
+        this.caches = caches;
+    }
+
     /**
      * Initial message flag.
      */
@@ -113,6 +140,27 @@ public UUID requestId() {
         return this.reqId;
     }
 
+    /**
+     * @param reqId Request id.
+     */
+    public void requestId(UUID reqId) {
+        this.reqId = reqId;
+    }
+
+    /**
+     * @return Flags.
+     */
+    public byte flags() {
+        return flags;
+    }
+
+    /**
+     * @param flags Flags.
+     */
+    public void flags(byte flags) {
+        this.flags = flags;
+    }
+
     /** {@inheritDoc} */
     @Override public String toString() {
         return S.toString(CacheStatisticsClearMessage.class, this);