Skip to content

Commit e98f384

Browse files
committed
merge fixes2
1 parent 3d82a46 commit e98f384

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

modules/core/src/test/java/org/apache/ignite/internal/util/distributed/MessagesPluginProvider.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,15 @@
1919

2020
import org.apache.ignite.internal.managers.communication.IgniteMessageFactoryImpl;
2121
import org.apache.ignite.internal.managers.discovery.DiscoveryMessageFactory;
22+
import org.apache.ignite.internal.util.typedef.internal.U;
2223
import org.apache.ignite.plugin.AbstractTestPluginProvider;
2324
import org.apache.ignite.plugin.ExtensionRegistry;
2425
import org.apache.ignite.plugin.PluginContext;
2526
import org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider;
2627
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
2728
import org.apache.ignite.testframework.GridTestUtils;
2829

30+
import static org.apache.ignite.marshaller.Marshallers.jdk;
2931
import static org.junit.Assert.assertTrue;
3032

3133
/** */
@@ -54,7 +56,7 @@ public static class MessagesInjectedTcpDiscoverySpi extends TcpDiscoverySpi {
5456
/** {@inheritDoc} */
5557
@Override protected void initLocalNode(int srvPort, boolean addExtAddrAttr) {
5658
GridTestUtils.setFieldValue(this, TcpDiscoverySpi.class, "msgFactory", new IgniteMessageFactoryImpl(
57-
new MessageFactoryProvider[] { new DiscoveryMessageFactory(null, null), FACTORY_PROVIDER}));
59+
new MessageFactoryProvider[] { new DiscoveryMessageFactory(jdk(), U.gridClassLoader()), FACTORY_PROVIDER}));
5860

5961
super.initLocalNode(srvPort, addExtAddrAttr);
6062
}

0 commit comments

Comments
 (0)