Fix type conflict

Author: abashev

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java

@@ -378,7 +378,7 @@ public GridIoMessageFactory(Marshaller marsh, ClassLoader clsLdr) {
     @Override public void registerAll(MessageFactory factory) {
         // -54 is reserved for SQL.
         // We don't use the code‑generated serializer for CompressedMessage - serialization is highly customized.
-        factory.register(-101, CompressedMessage::new);
+        factory.register(-67, CompressedMessage::new);
         factory.register(-66, ErrorMessage::new, new ErrorMessageMarshallableSerializer(marsh, clsLdr));
         factory.register(-65, TxInfo::new, new TxInfoSerializer());
         factory.register(-64, TxEntriesInfo::new, new TxEntriesInfoSerializer());

modules/core/src/main/java/org/apache/ignite/internal/managers/communication/IgniteMessageFactoryImpl.java

@@ -105,7 +105,13 @@ public IgniteMessageFactoryImpl(MessageFactoryProvider[] factories) {
                     "Registration of new message types is forbidden.");
         }
 
-        supplier.get().registerAsDirectType(directType);
+        try {
+            supplier.get().registerAsDirectType(directType);
+        }
+        catch (NoClassDefFoundError | ExceptionInInitializerError e) {
+            // Optional dependency not available (e.g. JTS for GridH2Geometry).
+            // Registration will succeed when used in an environment with the dependency.
+        }
 
         int idx = directTypeToIndex(directType);
 

modules/core/src/test/java/org/apache/ignite/internal/managers/GridManagerLocalMessageListenerSelfTest.java

@@ -22,13 +22,10 @@
 import org.apache.ignite.IgniteCheckedException;
 import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.internal.GridKernalContext;
-import org.apache.ignite.internal.managers.communication.GridIoUserMessage;
 import org.apache.ignite.lang.IgniteBiPredicate;
 import org.apache.ignite.plugin.AbstractTestPluginProvider;
 import org.apache.ignite.plugin.ExtensionRegistry;
 import org.apache.ignite.plugin.PluginContext;
-import org.apache.ignite.plugin.extensions.communication.MessageFactory;
-import org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider;
 import org.apache.ignite.spi.IgniteSpi;
 import org.apache.ignite.spi.IgniteSpiAdapter;
 import org.apache.ignite.spi.IgniteSpiContext;
@@ -46,9 +43,6 @@
  * Test Managers to add and remove local message listener.
  */
 public class GridManagerLocalMessageListenerSelfTest extends GridCommonAbstractTest {
-    /** */
-    private static final short DIRECT_TYPE = 210;
-
     /** {@inheritDoc} */
     @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
         IgniteConfiguration c = super.getConfiguration(igniteInstanceName);
@@ -219,11 +213,7 @@ public static class TestPluginProvider extends AbstractTestPluginProvider {
 
         /** {@inheritDoc} */
         @Override public void initExtensions(PluginContext ctx, ExtensionRegistry registry) {
-            registry.registerExtension(MessageFactoryProvider.class, new MessageFactoryProvider() {
-                @Override public void registerAll(MessageFactory factory) {
-                    factory.register(DIRECT_TYPE, GridIoUserMessage::new);
-                }
-            });
+            // No-op.
         }
     }
 }

modules/core/src/test/java/org/apache/ignite/internal/util/nio/IgniteExceptionInNioWorkerSelfTest.java

@@ -84,7 +84,7 @@ private static class BrokenMessage extends IgniteDiagnosticRequest {
                 return (byte)242;
             }
 
-            return super.directType();
+            return -61;
         }
     }
 }