You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/03/05 15:18:57 UTC
[activemq-artemis] branch master updated: NO-JIRA fix flaky
ReplicatedMultipleFailbackTest NPE
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new 57e85bb NO-JIRA fix flaky ReplicatedMultipleFailbackTest NPE
57e85bb is described below
commit 57e85bbc10d055bb0e2007a8b5f9817f4b97a265
Author: franz1981 <ni...@gmail.com>
AuthorDate: Fri Mar 5 14:49:43 2021 +0100
NO-JIRA fix flaky ReplicatedMultipleFailbackTest NPE
---
.../jmxmultiplefailback/ReplicatedMultipleFailbackTest.java | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java
index f354fe6..95a2346 100644
--- a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java
+++ b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/jmxmultiplefailback/ReplicatedMultipleFailbackTest.java
@@ -98,10 +98,14 @@ public class ReplicatedMultipleFailbackTest extends SmokeTestBase {
Map<String, Pair<String, String>> networkTopology = new HashMap<>(nodeCount);
for (int i = 0; i < nodeCount; i++) {
final JsonObject nodePair = nodeIDs.getJsonObject(i);
- final String nodeID = nodePair.getString("nodeID");
- final String live = nodePair.getString("live");
- final String backup = nodePair.getString("backup", null);
- networkTopology.put(nodeID, new Pair<>(live, backup));
+ try {
+ final String nodeID = nodePair.getString("nodeID");
+ final String live = nodePair.getString("live");
+ final String backup = nodePair.getString("backup", null);
+ networkTopology.put(nodeID, new Pair<>(live, backup));
+ } catch (Exception e) {
+ LOGGER.warnf(e, "Error on %s", nodePair);
+ }
}
return networkTopology;
}