Skip to content

Commit 3565659

Browse files
committed
Avoid race conditions by waiting for the log before creating the second consumer.
1 parent b381422 commit 3565659

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.activemq.command.ActiveMQQueue;
2727
import org.apache.activemq.usage.SystemUsage;
2828
import org.apache.activemq.util.DefaultTestAppender;
29+
import org.apache.activemq.util.Wait;
2930
import org.apache.logging.log4j.Level;
3031
import org.apache.logging.log4j.LogManager;
3132
import org.apache.logging.log4j.core.LogEvent;
@@ -154,6 +155,8 @@ public void append(LogEvent event) {
154155

155156
try {
156157

158+
assertTrue("Timed out waiting for cursor to block", Wait.waitFor(() -> gotExpectedLogEvent.get()));
159+
157160
MessageConsumer noDispatchConsumer = consumerSession.createConsumer(shouldBeStuckForDispatch);
158161

159162
Message m = noDispatchConsumer.receive(messageReceiveTimeout);

0 commit comments

Comments
 (0)