File tree Expand file tree Collapse file tree 2 files changed +12
-5
lines changed
spring-kafka/src/test/java/org/springframework/kafka/retrytopic Expand file tree Collapse file tree 2 files changed +12
-5
lines changed Original file line number Diff line number Diff line change 3636import org .springframework .kafka .support .converter .ConversionException ;
3737import org .springframework .kafka .support .serializer .DeserializationException ;
3838
39- import static org .assertj .core .api .Assertions .*;
39+ import static org .assertj .core .api .Assertions .assertThat ;
40+ import static org .assertj .core .api .Assertions .assertThatIllegalArgumentException ;
41+ import static org .assertj .core .api .Assertions .assertThatIllegalStateException ;
42+ import static org .assertj .core .api .Assertions .assertThatNoException ;
43+ import static org .assertj .core .api .Assertions .assertThatNullPointerException ;
4044
4145/**
4246 * @author Tomaz Fernandes
Original file line number Diff line number Diff line change 1616
1717package org .springframework .kafka .retrytopic ;
1818
19- import static org .assertj .core .api .Assertions .assertThat ;
20- import static org .assertj .core .api .Assertions .fail ;
21-
2219import java .util .HashMap ;
2320import java .util .Map ;
2421import java .util .concurrent .CountDownLatch ;
3027import org .apache .kafka .clients .producer .ProducerConfig ;
3128import org .apache .kafka .common .serialization .StringDeserializer ;
3229import org .apache .kafka .common .serialization .StringSerializer ;
33- import org .junit .jupiter .api .BeforeEach ;
3430import org .junit .jupiter .api .Test ;
3531import org .slf4j .Logger ;
3632import org .slf4j .LoggerFactory ;
6157import org .springframework .test .annotation .DirtiesContext ;
6258import org .springframework .test .context .junit .jupiter .SpringJUnitConfig ;
6359
60+ import static org .assertj .core .api .Assertions .assertThat ;
61+ import static org .assertj .core .api .Assertions .fail ;
62+
6463/**
6564 * @author Hyunggeol Lee
6665 * @since 4.0
@@ -219,11 +218,15 @@ public void shouldNotBeInvoked() {
219218 static class CountDownLatchContainer {
220219
221220 final CountDownLatch singleDltLatch = new CountDownLatch (1 );
221+
222222 final CountDownLatch multiDltLatch = new CountDownLatch (1 );
223+
223224 final CountDownLatch noDltProcessed = new CountDownLatch (1 );
224225
225226 final AtomicInteger singleDltInvocations = new AtomicInteger (0 );
227+
226228 final AtomicInteger multiDltInvocations = new AtomicInteger (0 );
229+
227230 final AtomicInteger noDltInvocations = new AtomicInteger (0 );
228231 }
229232
You can’t perform that action at this time.
0 commit comments