Skip to content

Commit 0f35cdd

Browse files
committed
Guard tests against changing subscription order.
See #2143
1 parent 174680b commit 0f35cdd

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerIntegrationTests.java

+4-2
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package org.springframework.data.redis.listener;
1717

1818
import static org.assertj.core.api.Assertions.*;
19+
import static org.awaitility.Awaitility.*;
1920

2021
import java.util.Arrays;
2122
import java.util.Collection;
@@ -207,8 +208,9 @@ public void onPatternSubscribed(byte[] pattern, long count) {
207208
received.await(2, TimeUnit.SECONDS);
208209
container.destroy();
209210

210-
assertThat(subscriptions1).hasValue(1);
211-
assertThat(subscriptions2).hasValue(1);
211+
await().until(() -> subscriptions1.get() > 0 || subscriptions2.get() > 0);
212+
213+
assertThat(subscriptions1.get() + subscriptions2.get()).isEqualTo(1);
212214
}
213215

214216
interface CompositeListener extends MessageListener, SubscriptionListener {

0 commit comments

Comments
 (0)