GEODE-9606: Fix flaky PubSubIntegrationTest.testPatternWithoutAGlob (#…

…6884)
apache · Sep 21, 2021 · cf1b35c · cf1b35c
1 parent 19f55ad
commit cf1b35c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...t/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java b/...t/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
@@ -757,10 +757,12 @@ public void testPatternWithoutAGlob() {
     waitFor(() -> mockSubscriber.getSubscribedChannels() == 2);
 
     mockSubscriber.prepareMessagesReceivedLatch(1);
+    mockSubscriber.preparePMessagesReceivedLatch(1);
     Long result = publisher.publish("salutations", "hello");
 
     assertThat(result).isEqualTo(2);
     mockSubscriber.awaitMessagesReceived();
+    mockSubscriber.awaitPMessagesReceived();
 
     mockSubscriber.punsubscribe("salutations");
     waitFor(() -> mockSubscriber.getSubscribedChannels() == 1);