IGNITE-27414 : Use MessageSerializer for TcpDiscoveryClientReconnectMessage v3 - codegen

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MarshalableMessage.java → modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMarshalableMessage.java

@@ -23,7 +23,7 @@
 /**
  *
  */
-public interface MarshalableMessage extends CalciteMessage {
+public interface CalciteMarshalableMessage extends CalciteMessage {
     /**
      * Prepares the message before sending.
      *

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java

@@ -179,8 +179,8 @@ public FailureProcessor failureProcessor() {
     /** */
     protected void prepareMarshal(Message msg) throws IgniteCheckedException {
         try {
-            if (msg instanceof MarshalableMessage)
-                ((MarshalableMessage)msg).prepareMarshal(ctx);
+            if (msg instanceof CalciteMarshalableMessage)
+                ((CalciteMarshalableMessage)msg).prepareMarshal(ctx);
         }
         catch (Exception e) {
             failureProcessor().process(new FailureContext(FailureType.CRITICAL_ERROR, e));
@@ -192,8 +192,8 @@ protected void prepareMarshal(Message msg) throws IgniteCheckedException {
     /** */
     protected void prepareUnmarshal(Message msg) throws IgniteCheckedException {
         try {
-            if (msg instanceof MarshalableMessage)
-                ((MarshalableMessage)msg).prepareUnmarshal(ctx);
+            if (msg instanceof CalciteMarshalableMessage)
+                ((CalciteMarshalableMessage)msg).prepareUnmarshal(ctx);
         }
         catch (Exception e) {
             failureProcessor().process(new FailureContext(FailureType.CRITICAL_ERROR, e));

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java

@@ -27,7 +27,7 @@
 /**
  *
  */
-public class QueryBatchMessage implements MarshalableMessage, ExecutionContextAware {
+public class QueryBatchMessage implements CalciteMarshalableMessage, ExecutionContextAware {
     /** */
     @Order(0)
     UUID qryId;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java

@@ -31,7 +31,7 @@
 /**
  *
  */
-public class QueryStartRequest implements MarshalableMessage, ExecutionContextAware {
+public class QueryStartRequest implements CalciteMarshalableMessage, ExecutionContextAware {
     /** */
     @Order(0)
     String schema;

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ValueMessage.java

@@ -21,7 +21,7 @@
 import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
 
 /** */
-public interface ValueMessage extends MarshalableMessage {
+public interface ValueMessage extends CalciteMarshalableMessage {
     /**
      * @return Wrapped value.
      */

modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/FragmentDescription.java

@@ -23,13 +23,13 @@
 import java.util.UUID;
 import org.apache.ignite.internal.Order;
 import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
-import org.apache.ignite.internal.processors.query.calcite.message.MarshalableMessage;
+import org.apache.ignite.internal.processors.query.calcite.message.CalciteMarshalableMessage;
 import org.apache.ignite.internal.processors.query.calcite.message.MessageType;
 import org.apache.ignite.internal.util.UUIDCollectionMessage;
 import org.apache.ignite.internal.util.typedef.internal.U;
 
 /** */
-public class FragmentDescription implements MarshalableMessage {
+public class FragmentDescription implements CalciteMarshalableMessage {
     /** */
     @Order(0)
     long fragmentId;

modules/codegen/src/main/java/org/apache/ignite/internal/MessageProcessor.java

@@ -68,6 +68,12 @@ public class MessageProcessor extends AbstractProcessor {
     /** Base interface that every message must implement. */
     static final String MESSAGE_INTERFACE = "org.apache.ignite.plugin.extensions.communication.Message";
 
+    /** Compressed message. */
+    static final String COMPRESSED_MESSAGE_INTERFACE = "org.apache.ignite.internal.managers.communication.CompressedMessage";
+
+    /** Externalizable message. */
+    static final String MARSHALLABLE_MESSAGE_INTERFACE = "org.apache.ignite.plugin.extensions.communication.MarshallableMessage";
+
     /** This is the only message with zero fields. A serializer must be generated due to restrictions in our communication process. */
     static final String HANDSHAKE_WAIT_MESSAGE = "org.apache.ignite.spi.communication.tcp.messages.HandshakeWaitMessage";