[geode] branch develop updated: GEODE-9606: Fix flaky PubSubIntegrationTest.testPatternWithoutAGlob (#6884)

[jensdeppe]

This is an automated email from the ASF dual-hosted git repository.

jensdeppe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
     new cf1b35c  GEODE-9606: Fix flaky 
PubSubIntegrationTest.testPatternWithoutAGlob (#6884)
cf1b35c is described below

commit cf1b35c083d526a02851c06f44a6eda78963d16f
Author: Jens Deppe <jde...@vmware.com>
AuthorDate: Tue Sep 21 07:38:41 2021 -0700

    GEODE-9606: Fix flaky PubSubIntegrationTest.testPatternWithoutAGlob (#6884)
---
 .../redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/geode-apis-compatible-with-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
 
b/geode-apis-compatible-with-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
index 207f8bd..fdef0be 100644
--- 
a/geode-apis-compatible-with-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
+++ 
b/geode-apis-compatible-with-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/AbstractPubSubIntegrationTest.java
@@ -757,10 +757,12 @@ public abstract class AbstractPubSubIntegrationTest 
implements RedisIntegrationT
     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);