File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
spring-kafka/src/test/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2018-2022 the original author or authors.
2
+ * Copyright 2018-2024 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
@@ -77,7 +77,8 @@ public void testOOMCMLC() throws Exception {
77
77
containerProps.setClientId("clientId");
78
78
ConcurrentMessageListenerContainer<Integer, String> container =
79
79
new ConcurrentMessageListenerContainer<>(cf, containerProps);
80
- CountDownLatch stopLatch = new CountDownLatch(1);
80
+ // concurrent container publishes one time, child container publishes concurrency time.
81
+ CountDownLatch stopLatch = new CountDownLatch(2);
81
82
container.setApplicationEventPublisher(e -> {
82
83
if (e instanceof ContainerStoppedEvent) {
83
84
stopLatch.countDown();
You can’t perform that action at this time.
0 commit comments