diff --git a/rts/lra/test/basic/src/test/java/io/narayana/lra/arquillian/FailedLRAIT.java b/rts/lra/test/basic/src/test/java/io/narayana/lra/arquillian/FailedLRAIT.java index 8d71b6ee20..b25d844d8f 100644 --- a/rts/lra/test/basic/src/test/java/io/narayana/lra/arquillian/FailedLRAIT.java +++ b/rts/lra/test/basic/src/test/java/io/narayana/lra/arquillian/FailedLRAIT.java @@ -254,11 +254,14 @@ private URI invokeInTransaction(String resourcePrefix, String resourcePath, int */ private boolean validateStateAndRemove(URI lra, LRAStatus state) { JsonArray failedRecords = getFailedRecords(lra); + for (JsonValue failedLRA : failedRecords) { - String lraId = failedLRA.asJsonObject().getString("lraId"); - lraId = lraId.replaceAll("\\\\", ""); + String lraId = failedLRA.asJsonObject().getString("lraId") + .replaceAll("\\\\", ""); + if (lraId.contains(lra.toASCIIString())) { String status = failedLRA.asJsonObject().getString("status"); + if (status.equals(state.name())) { // remove the failed LRA Assert.assertEquals("Could not remove log", @@ -269,6 +272,9 @@ private boolean validateStateAndRemove(URI lra, LRAStatus state) { } } + System.out.printf("lra not in failed list:%n LRA=%s%n state=%s%n json=%s%n", + lra, state, failedRecords); + return false; }