Skip to content

Commit f147a48

Browse files
committed
test fix
1 parent c9390c5 commit f147a48

2 files changed

Lines changed: 7 additions & 1 deletion

File tree

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -288,6 +288,9 @@ public class CoreMessagesProvider implements MessageFactoryProvider {
288288
/** Handshake wait message type. */
289289
public static final short HANDSHAKE_WAIT_MSG_TYPE = HANDSHAKE_MSG_TYPE + 1;
290290

291+
/** */
292+
public static final short MAX_MESSAGE_ID = 15_000;
293+
291294
/** Binary marshaller. */
292295
private final Marshaller schemaAwareMarhaller;
293296

@@ -638,6 +641,8 @@ public CoreMessagesProvider(Marshaller schemaAwareMarhaller, Marshaller schemaLe
638641
register(IgniteDiagnosticRequest.class);
639642
register(IgniteDiagnosticResponse.class);
640643
register(WalStateAckMessage.class);
644+
645+
assert msgIdx <= MAX_MESSAGE_ID;
641646
}
642647

643648
/** */

modules/core/src/test/java/org/apache/ignite/spi/MessagesPluginProvider.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
import java.util.function.Supplier;
2121
import org.apache.ignite.IgniteCheckedException;
22+
import org.apache.ignite.internal.CoreMessagesProvider;
2223
import org.apache.ignite.internal.util.typedef.internal.U;
2324
import org.apache.ignite.plugin.AbstractTestPluginProvider;
2425
import org.apache.ignite.plugin.ExtensionRegistry;
@@ -39,7 +40,7 @@ public class MessagesPluginProvider extends AbstractTestPluginProvider {
3940
@SafeVarargs
4041
public MessagesPluginProvider(Class<? extends Message>... msgs) {
4142
msgFactoryProvider = f -> {
42-
short directType = 10_000;
43+
short directType = CoreMessagesProvider.MAX_MESSAGE_ID + 1;
4344

4445
for (Class<? extends Message> msg : msgs) {
4546
Supplier<Message> msgSupp = () -> {

0 commit comments

Comments
 (0)