From 00fa82509fff61579010e2904be825e3295b398c Mon Sep 17 00:00:00 2001 From: Ilya Shishkov Date: Wed, 13 May 2026 13:49:30 +0300 Subject: [PATCH] IGNITE-28667 Initialize message factory provider for extensions --- .../org/apache/ignite/internal/IgniteKernal.java | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java index e30b0c453a7c5..b94f0df3ca02c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java @@ -1326,11 +1326,8 @@ private void initMessageFactory() throws IgniteCheckedException { for (IgniteComponentType compType : IgniteComponentType.values()) { MessageFactoryProvider f = compType.messageFactory(); - if (f != null) { - initProvider(f, resolvedClsLdr); - + if (f != null) compMsgs.add(f); - } } DiscoverySpi discoSpi = ctx.config().getDiscoverySpi(); @@ -1338,16 +1335,16 @@ private void initMessageFactory() throws IgniteCheckedException { if (discoSpi instanceof IgniteDiscoverySpi) { MessageFactoryProvider discoMsgs = ((IgniteDiscoverySpi)discoSpi).messageFactoryProvider(); - if (discoMsgs != null) { - initProvider(discoMsgs, resolvedClsLdr); - + if (discoMsgs != null) compMsgs.add(discoMsgs); - } } if (!compMsgs.isEmpty()) msgs = F.concat(msgs, compMsgs.toArray(new MessageFactoryProvider[compMsgs.size()])); + for (MessageFactoryProvider msg : msgs) + initProvider(msg, resolvedClsLdr); + msgFactory = new IgniteMessageFactoryImpl(msgs); }