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