We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 66d5d74 commit 27c1744Copy full SHA for 27c1744
1 file changed
activemq-unit-tests/src/test/java/org/apache/activemq/store/jdbc/XACompletionTest.java
@@ -249,6 +249,7 @@ public void testStatsAndBrowseAfterAckPreparedRolledback() throws Exception {
249
resource.recover(XAResource.TMSTARTRSCAN);
250
resource.recover(XAResource.TMNOFLAGS);
251
252
+ assertTrue("Timed out waiting for queue state to stabilize", Wait.waitFor(() -> proxy.getInFlightCount() == 0L && proxy.getQueueSize() == 10L && proxy.cursorSize() == 0));
253
assertEquals("prefetch 0", 0, proxy.getInFlightCount());
254
assertEquals("size 0", 10, proxy.getQueueSize());
255
assertEquals("size 0", 0, proxy.cursorSize());
0 commit comments