We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5af2d2e commit 00a5352Copy full SHA for 00a5352
1 file changed
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java
@@ -26,6 +26,7 @@
26
import org.apache.activemq.command.ActiveMQQueue;
27
import org.apache.activemq.usage.SystemUsage;
28
import org.apache.activemq.util.DefaultTestAppender;
29
+import org.apache.activemq.util.Wait;
30
import org.apache.logging.log4j.Level;
31
import org.apache.logging.log4j.LogManager;
32
import org.apache.logging.log4j.core.LogEvent;
@@ -154,6 +155,8 @@ public void append(LogEvent event) {
154
155
156
try {
157
158
+ assertTrue("Timed out waiting for cursor to block", Wait.waitFor(() -> gotExpectedLogEvent.get()));
159
+
160
MessageConsumer noDispatchConsumer = consumerSession.createConsumer(shouldBeStuckForDispatch);
161
162
Message m = noDispatchConsumer.receive(messageReceiveTimeout);
0 commit comments