IGNITE-28540 : Cleanup schema-aware message serialization

modules/core/src/main/java/org/apache/ignite/internal/CoreMessagesProvider.java

@@ -330,7 +330,7 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
         msgIdx = 5000;
         // We don't use the code‑generated serializer for CompressedMessage - serialization is highly customized.
         factory.register(msgIdx++, CompressedMessage::new);
-        withSchema(ErrorMessage.class);
+        withNoSchema(ErrorMessage.class);
         withNoSchema(InetSocketAddressMessage.class);
         withNoSchema(InetAddressMessage.class);
         withNoSchema(TcpDiscoveryNode.class);
@@ -435,97 +435,97 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
 
         // [10000 - 10200]: Transaction and lock related messages. Most of the originally comes from Communication.
         msgIdx = 10000;
-        withSchema(TxInfo.class);
-        withSchema(TxEntriesInfo.class);
-        withSchema(TxLock.class);
-        withSchema(TxLocksRequest.class);
-        withSchema(TxLocksResponse.class);
-        withSchema(IgniteTxKey.class);
-        withSchema(IgniteTxEntry.class);
-        withSchema(TxEntryValueHolder.class);
-        withSchema(GridCacheTxRecoveryRequest.class);
-        withSchema(GridCacheTxRecoveryResponse.class);
-        withSchema(GridDistributedTxFinishRequest.class);
-        withSchema(GridDistributedTxFinishResponse.class);
-        withSchema(GridDistributedTxPrepareRequest.class);
-        withSchema(GridDistributedTxPrepareResponse.class);
-        withSchema(GridDhtTxFinishRequest.class);
-        withSchema(GridDhtTxFinishResponse.class);
-        withSchema(GridDhtTxPrepareRequest.class);
-        withSchema(GridDhtTxPrepareResponse.class);
-        withSchema(GridNearTxFinishRequest.class);
-        withSchema(GridNearTxFinishResponse.class);
-        withSchema(GridNearTxPrepareRequest.class);
-        withSchema(GridNearTxPrepareResponse.class);
-        withSchema(GridDhtLockRequest.class);
-        withSchema(GridDhtLockResponse.class);
-        withSchema(GridDhtUnlockRequest.class);
-        withSchema(GridNearLockRequest.class);
-        withSchema(GridNearLockResponse.class);
-        withSchema(GridNearUnlockRequest.class);
-        withSchema(GridDistributedLockRequest.class);
-        withSchema(GridDistributedLockResponse.class);
-        withSchema(GridDhtTxOnePhaseCommitAckRequest.class);
-        withSchema(TransactionAttributesAwareRequest.class);
+        withNoSchema(TxInfo.class);
+        withNoSchema(TxEntriesInfo.class);
+        withNoSchema(TxLock.class);
+        withNoSchema(TxLocksRequest.class);
+        withNoSchema(TxLocksResponse.class);
+        withNoSchema(IgniteTxKey.class);
+        withNoSchema(IgniteTxEntry.class);
+        withNoSchema(TxEntryValueHolder.class);
+        withNoSchema(GridCacheTxRecoveryRequest.class);
+        withNoSchema(GridCacheTxRecoveryResponse.class);
+        withNoSchema(GridDistributedTxFinishRequest.class);
+        withNoSchema(GridDistributedTxFinishResponse.class);
+        withNoSchema(GridDistributedTxPrepareRequest.class);
+        withNoSchema(GridDistributedTxPrepareResponse.class);
+        withNoSchema(GridDhtTxFinishRequest.class);
+        withNoSchema(GridDhtTxFinishResponse.class);
+        withNoSchema(GridDhtTxPrepareRequest.class);
+        withNoSchema(GridDhtTxPrepareResponse.class);
+        withNoSchema(GridNearTxFinishRequest.class);
+        withNoSchema(GridNearTxFinishResponse.class);
+        withNoSchema(GridNearTxPrepareRequest.class);
+        withNoSchema(GridNearTxPrepareResponse.class);
+        withNoSchema(GridDhtLockRequest.class);
+        withNoSchema(GridDhtLockResponse.class);
+        withNoSchema(GridDhtUnlockRequest.class);
+        withNoSchema(GridNearLockRequest.class);
+        withNoSchema(GridNearLockResponse.class);
+        withNoSchema(GridNearUnlockRequest.class);
+        withNoSchema(GridDistributedLockRequest.class);
+        withNoSchema(GridDistributedLockResponse.class);
+        withNoSchema(GridDhtTxOnePhaseCommitAckRequest.class);
+        withNoSchema(TransactionAttributesAwareRequest.class);
 
         // [10300 - 10500]: Cache, DHT messages.
         msgIdx = 10300;
-        withSchema(GridDhtForceKeysRequest.class);
-        withSchema(GridDhtForceKeysResponse.class);
-        withSchema(GridDhtAtomicDeferredUpdateResponse.class);
-        withSchema(GridDhtAtomicUpdateRequest.class);
-        withSchema(GridDhtAtomicUpdateResponse.class);
-        withSchema(GridNearAtomicFullUpdateRequest.class);
-        withSchema(GridDhtAtomicSingleUpdateRequest.class);
-        withSchema(GridNearAtomicUpdateResponse.class);
-        withSchema(GridNearAtomicSingleUpdateRequest.class);
-        withSchema(GridNearAtomicSingleUpdateInvokeRequest.class);
-        withSchema(GridNearAtomicSingleUpdateFilterRequest.class);
-        withSchema(GridNearAtomicCheckUpdateRequest.class);
-        withSchema(NearCacheUpdates.class);
-        withSchema(GridNearGetRequest.class);
-        withSchema(GridNearGetResponse.class);
-        withSchema(GridNearSingleGetRequest.class);
-        withSchema(GridNearSingleGetResponse.class);
-        withSchema(GridDhtAtomicNearResponse.class);
-        withSchema(GridCacheTtlUpdateRequest.class);
-        withSchema(GridCacheReturn.class);
-        withSchema(GridCacheEntryInfo.class);
-        withSchema(CacheInvokeDirectResult.class);
-        withSchema(GridCacheRawVersionedEntry.class);
-        withSchema(CacheEvictionEntry.class);
-        withSchema(CacheEntryPredicateAdapter.class);
-        withSchema(GridContinuousMessage.class);
-        withSchema(ContinuousRoutineStartResultMessage.class);
-        withSchema(UpdateErrors.class);
-        withSchema(LatchAckMessage.class);
-        withSchema(AtomicApplicationAttributesAwareRequest.class);
+        withNoSchema(GridDhtForceKeysRequest.class);
+        withNoSchema(GridDhtForceKeysResponse.class);
+        withNoSchema(GridDhtAtomicDeferredUpdateResponse.class);
+        withNoSchema(GridDhtAtomicUpdateRequest.class);
+        withNoSchema(GridDhtAtomicUpdateResponse.class);
+        withNoSchema(GridNearAtomicFullUpdateRequest.class);
+        withNoSchema(GridDhtAtomicSingleUpdateRequest.class);
+        withNoSchema(GridNearAtomicUpdateResponse.class);
+        withNoSchema(GridNearAtomicSingleUpdateRequest.class);
+        withNoSchema(GridNearAtomicSingleUpdateInvokeRequest.class);
+        withNoSchema(GridNearAtomicSingleUpdateFilterRequest.class);
+        withNoSchema(GridNearAtomicCheckUpdateRequest.class);
+        withNoSchema(NearCacheUpdates.class);
+        withNoSchema(GridNearGetRequest.class);
+        withNoSchema(GridNearGetResponse.class);
+        withNoSchema(GridNearSingleGetRequest.class);
+        withNoSchema(GridNearSingleGetResponse.class);
+        withNoSchema(GridDhtAtomicNearResponse.class);
+        withNoSchema(GridCacheTtlUpdateRequest.class);
+        withNoSchema(GridCacheReturn.class);
+        withNoSchema(GridCacheEntryInfo.class);
+        withNoSchema(CacheInvokeDirectResult.class);
+        withNoSchema(GridCacheRawVersionedEntry.class);
+        withNoSchema(CacheEvictionEntry.class);
+        withNoSchema(CacheEntryPredicateAdapter.class);
+        withNoSchema(GridContinuousMessage.class);
+        withNoSchema(ContinuousRoutineStartResultMessage.class);
+        withNoSchema(UpdateErrors.class);
+        withNoSchema(LatchAckMessage.class);
+        withNoSchema(AtomicApplicationAttributesAwareRequest.class);
         withNoSchema(StartRequestData.class);
         withNoSchema(StartRoutineDiscoveryMessage.class);
         withNoSchema(StartRoutineAckDiscoveryMessage.class);
         withNoSchema(StartRoutineDiscoveryMessageV2.class);
 
         // [10600-10800]: Affinity & partition maps.
         msgIdx = 10600;
-        withSchema(GridDhtAffinityAssignmentRequest.class);
-        withSchema(GridDhtAffinityAssignmentResponse.class);
-        withSchema(CacheGroupAffinityMessage.class);
-        withSchema(ExchangeInfo.class);
-        withSchema(PartitionUpdateCountersMessage.class);
-        withSchema(CachePartitionPartialCountersMap.class);
-        withSchema(IgniteDhtDemandedPartitionsMap.class);
-        withSchema(CachePartitionFullCountersMap.class);
-        withSchema(GroupPartitionIdPair.class);
-        withSchema(GridPartitionStateMap.class);
-        withSchema(GridDhtPartitionMap.class);
-        withSchema(GridDhtPartitionFullMap.class);
+        withNoSchema(GridDhtAffinityAssignmentRequest.class);
+        withNoSchema(GridDhtAffinityAssignmentResponse.class);
+        withNoSchema(CacheGroupAffinityMessage.class);
+        withNoSchema(ExchangeInfo.class);
+        withNoSchema(PartitionUpdateCountersMessage.class);
+        withNoSchema(CachePartitionPartialCountersMap.class);
+        withNoSchema(IgniteDhtDemandedPartitionsMap.class);
+        withNoSchema(CachePartitionFullCountersMap.class);
+        withNoSchema(GroupPartitionIdPair.class);
+        withNoSchema(GridPartitionStateMap.class);
+        withNoSchema(GridDhtPartitionMap.class);
+        withNoSchema(GridDhtPartitionFullMap.class);
         withNoSchema(GridDhtPartitionExchangeId.class);
         withNoSchema(GridCheckpointRequest.class);
-        withSchema(GridDhtPartitionDemandMessage.class);
-        withSchema(GridDhtPartitionSupplyMessage.class);
-        withSchema(GridDhtPartitionsFullMessage.class);
-        withSchema(GridDhtPartitionsSingleMessage.class);
-        withSchema(GridDhtPartitionsSingleRequest.class);
+        withNoSchema(GridDhtPartitionDemandMessage.class);
+        withNoSchema(GridDhtPartitionSupplyMessage.class);
+        withNoSchema(GridDhtPartitionsFullMessage.class);
+        withNoSchema(GridDhtPartitionsSingleMessage.class);
+        withNoSchema(GridDhtPartitionsSingleRequest.class);
 
         // [10900-11100]: Query, schema and SQL related messages.
         msgIdx = 10900;
@@ -538,26 +538,26 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
         withNoSchema(SchemaProposeDiscoveryMessage.class);
         withNoSchema(SchemaFinishDiscoveryMessage.class);
         withNoSchema(QueryField.class);
-        withSchema(GridCacheSqlQuery.class);
-        withSchema(GridCacheQueryRequest.class);
-        withSchema(GridCacheQueryResponse.class);
-        withSchema(GridQueryCancelRequest.class);
-        withSchema(GridQueryFailResponse.class);
-        withSchema(GridQueryNextPageRequest.class);
-        withSchema(GridQueryNextPageResponse.class);
-        withSchema(GridQueryKillRequest.class);
-        withSchema(GridQueryKillResponse.class);
-        withSchema(IndexKeyDefinition.class);
-        withSchema(IndexKeyTypeSettings.class);
-        withSchema(IndexQueryResultMeta.class);
+        withNoSchema(GridCacheSqlQuery.class);
+        withNoSchema(GridCacheQueryRequest.class);
+        withNoSchema(GridCacheQueryResponse.class);
+        withNoSchema(GridQueryCancelRequest.class);
+        withNoSchema(GridQueryFailResponse.class);
+        withNoSchema(GridQueryNextPageRequest.class);
+        withNoSchema(GridQueryNextPageResponse.class);
+        withNoSchema(GridQueryKillRequest.class);
+        withNoSchema(GridQueryKillResponse.class);
+        withNoSchema(IndexKeyDefinition.class);
+        withNoSchema(IndexKeyTypeSettings.class);
+        withNoSchema(IndexQueryResultMeta.class);
         withNoSchema(StatisticsKeyMessage.class);
         withNoSchema(StatisticsDecimalMessage.class);
         withNoSchema(StatisticsObjectData.class);
         withNoSchema(StatisticsColumnData.class);
         withNoSchema(StatisticsRequest.class);
         withNoSchema(StatisticsResponse.class);
         withNoSchema(CacheContinuousQueryBatchAck.class);
-        withSchema(CacheContinuousQueryEntry.class);
+        withNoSchema(CacheContinuousQueryEntry.class);
 
         // [11200 - 11300]: Compute, distributed process messages.
         msgIdx = 11200;
@@ -578,18 +578,18 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
         withNoSchema(NodeIdMessage.class);
         withNoSchema(HandshakeMessage.class);
         withNoSchema(HandshakeWaitMessage.class);
-        withSchema(GridIoMessage.class);
+        withNoSchema(GridIoMessage.class);
         withNoSchema(IgniteIoTestMessage.class);
-        withSchema(GridIoUserMessage.class);
-        withSchema(GridIoSecurityAwareMessage.class);
+        withNoSchema(GridIoUserMessage.class);
+        withNoSchema(GridIoSecurityAwareMessage.class);
         withNoSchema(RecoveryLastReceivedMessage.class);
         withNoSchema(TcpInverseConnectionResponseMessage.class);
         withNoSchema(SessionChannelMessage.class);
 
         // [11700 - 11800]: Datastreamer messages.
         msgIdx = 11700;
         withNoSchema(DataStreamerUpdatesHandlerResult.class);
-        withSchema(DataStreamerEntry.class);
+        withNoSchema(DataStreamerEntry.class);
         withNoSchema(DataStreamerRequest.class);
         withNoSchema(DataStreamerResponse.class);
 
@@ -636,8 +636,8 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
         withSchema(GridEventStorageMessage.class);
         withNoSchema(ChangeGlobalStateMessage.class);
         withNoSchema(GridChangeGlobalStateMessageResponse.class);
-        withSchema(IgniteDiagnosticRequest.class);
-        withSchema(IgniteDiagnosticResponse.class);
+        withNoSchema(IgniteDiagnosticRequest.class);
+        withNoSchema(IgniteDiagnosticResponse.class);
         withNoSchema(WalStateAckMessage.class);
 
         assert msgIdx <= MAX_MESSAGE_ID;