You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by tk...@apache.org on 2024/02/02 09:10:46 UTC
(ignite-3) branch main updated: IGNITE-21424 ItScaleCubeNetworkMessagingTest.reconnectsAfterConnectionDrop causes an NPE to be logged (#3144)
This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 03237db87d IGNITE-21424 ItScaleCubeNetworkMessagingTest.reconnectsAfterConnectionDrop causes an NPE to be logged (#3144)
03237db87d is described below
commit 03237db87dfb3b34d813881a8bbe14d218e4cfad
Author: Roman Puchkovskiy <ro...@gmail.com>
AuthorDate: Fri Feb 2 13:10:40 2024 +0400
IGNITE-21424 ItScaleCubeNetworkMessagingTest.reconnectsAfterConnectionDrop causes an NPE to be logged (#3144)
---
.../network/scalecube/ItScaleCubeNetworkMessagingTest.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git a/modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItScaleCubeNetworkMessagingTest.java b/modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItScaleCubeNetworkMessagingTest.java
index a1f0706eda..34531a25a5 100644
--- a/modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItScaleCubeNetworkMessagingTest.java
+++ b/modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ItScaleCubeNetworkMessagingTest.java
@@ -17,7 +17,6 @@
package org.apache.ignite.network.scalecube;
-import static java.util.Objects.requireNonNull;
import static java.util.concurrent.TimeUnit.SECONDS;
import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toUnmodifiableList;
@@ -591,11 +590,9 @@ class ItScaleCubeNetworkMessagingTest {
receiver.messagingService().addMessageHandler(
TestMessageTypes.class,
(message, senderConsistentId, correlationId) -> {
- receiver.messagingService().respond(
- sender.topologyService().localMember(),
- message,
- requireNonNull(correlationId)
- );
+ if (correlationId != null) {
+ receiver.messagingService().respond(sender.topologyService().localMember(), message, correlationId);
+ }
}
);