Skip to content

Commit 2162583

Browse files
committed
merge fixes
1 parent 30502f7 commit 2162583

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/DiscoveryMessageFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,7 @@ public DiscoveryMessageFactory(@Nullable Marshaller cstDataMarshall, @Nullable C
226226
factory.register((short)27, DistributedMetaStorageCasAckMessage::new, new DistributedMetaStorageCasAckMessageSerializer());
227227
factory.register((short)28, TcpDiscoveryClientReconnectMessage::new,
228228
new TcpDiscoveryClientReconnectMessageMarshallableSerializer(cstDataMarshall, cstDataMarshallClsLdr));
229-
factory.register((short)24, FullMessage::new, new FullMessageSerializer());
229+
factory.register((short)29, FullMessage::new, new FullMessageSerializer());
230230

231231
factory.register((short)86, GridCacheVersion::new, new GridCacheVersionSerializer());
232232

modules/core/src/main/java/org/apache/ignite/internal/util/distributed/FullMessage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ public Map<UUID, Throwable> error() {
113113

114114
/** {@inheritDoc} */
115115
@Override public short directType() {
116-
return 24;
116+
return 29;
117117
}
118118

119119
/** {@inheritDoc} */

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public static class MessagesInjectedTcpDiscoverySpi extends TcpDiscoverySpi {
5454
/** {@inheritDoc} */
5555
@Override protected void initLocalNode(int srvPort, boolean addExtAddrAttr) {
5656
GridTestUtils.setFieldValue(this, TcpDiscoverySpi.class, "msgFactory", new IgniteMessageFactoryImpl(
57-
new MessageFactoryProvider[] { new DiscoveryMessageFactory(), FACTORY_PROVIDER}));
57+
new MessageFactoryProvider[] { new DiscoveryMessageFactory(null, null), FACTORY_PROVIDER}));
5858

5959
super.initLocalNode(srvPort, addExtAddrAttr);
6060
}

0 commit comments

Comments
 (0)