Skip to content

Commit 69dd43a

Browse files
committed
Add more info to test assertion
1 parent 0eb471f commit 69dd43a

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/test/java/com/rabbitmq/stream/impl/RecoveryClusterTest.java

+4-3
Original file line numberDiff line numberDiff line change
@@ -157,28 +157,29 @@ void clusterRestart(boolean useLoadBalancer, boolean forceLeader) throws Interru
157157
Thread.sleep(BACK_OFF_DELAY_POLICY.delay(0).multipliedBy(2).toMillis());
158158

159159
List<Tuple2<String, Sync>> streamsSyncs =
160-
producers.stream().map(p -> of(p.stream(), p.waitForNewMessages(100))).collect(toList());
160+
producers.stream().map(p -> of(p.stream(), p.waitForNewMessages(1000))).collect(toList());
161161
streamsSyncs.forEach(
162162
t -> {
163163
LOGGER.info("Checking publisher to {} still publishes", t._1());
164164
assertThat(t._2()).completes();
165165
LOGGER.info("Publisher to {} still publishes", t._1());
166166
});
167167

168-
syncs = consumers.stream().map(c -> c.waitForNewMessages(100)).collect(toList());
168+
syncs = consumers.stream().map(c -> c.waitForNewMessages(1000)).collect(toList());
169169
syncs.forEach(s -> assertThat(s).completes());
170170

171171
Map<String, Long> committedChunkIdPerStream = new LinkedHashMap<>(streamCount);
172172
streams.forEach(
173173
s ->
174174
committedChunkIdPerStream.put(s, environment.queryStreamStats(s).committedChunkId()));
175175

176-
syncs = producers.stream().map(p -> p.waitForNewMessages(100)).collect(toList());
176+
syncs = producers.stream().map(p -> p.waitForNewMessages(1000)).collect(toList());
177177
syncs.forEach(s -> assertThat(s).completes());
178178

179179
streams.forEach(
180180
s -> {
181181
assertThat(environment.queryStreamStats(s).committedChunkId())
182+
.as("Committed chunk ID did not increase")
182183
.isGreaterThan(committedChunkIdPerStream.get(s));
183184
});
184185

0 commit comments

Comments
 (0)