From e7866c6fd494a00c9ba22a0bd4e62cae1759529f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 27 Aug 2024 11:25:28 -0400 Subject: [PATCH] Remove compiler warnings in ConcurrentMessageListenerContainerTests --- .../ConcurrentMessageListenerContainerTests.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java index b197095181..b699f68098 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainerTests.java @@ -1019,8 +1019,8 @@ protected Consumer createKafkaConsumer(String groupId, String c container.start(); - MessageListenerContainer childContainer0 = container.getContainers().get(0); - MessageListenerContainer childContainer1 = container.getContainers().get(1); + KafkaMessageListenerContainer childContainer0 = container.getContainers().get(0); + KafkaMessageListenerContainer childContainer1 = container.getContainers().get(1); ContainerTestUtils.waitForAssignment(container, embeddedKafka.getPartitionsPerTopic()); assertThat(container.getAssignedPartitions()).hasSize(2); @@ -1062,9 +1062,9 @@ protected Consumer createKafkaConsumer(String groupId, String c assertThat(childContainer1.isRunning()).isTrue(); assertThat(childContainer0.isRunning()).isFalse(); assertThat(container.getContainers()). - contains((KafkaMessageListenerContainer) childContainer0); + contains(childContainer0); assertThat(container.getContainers()). - contains((KafkaMessageListenerContainer) childContainer1); + contains(childContainer1); container.stop(); @@ -1076,16 +1076,16 @@ protected Consumer createKafkaConsumer(String groupId, String c assertThat(concurrentContainerStopLatch.await(30, TimeUnit.SECONDS)).isTrue(); assertThat(container.getContainers()). - doesNotContain((KafkaMessageListenerContainer) childContainer0); + doesNotContain(childContainer0); assertThat(container.getContainers()). - doesNotContain((KafkaMessageListenerContainer) childContainer1); + doesNotContain(childContainer1); // Accept this start container.start(); assertThat(container.getContainers()). - doesNotContain((KafkaMessageListenerContainer) childContainer0); + doesNotContain(childContainer0); assertThat(container.getContainers()). - doesNotContain((KafkaMessageListenerContainer) childContainer1); + doesNotContain(childContainer1); container.getContainers().forEach(containerForEach -> containerForEach.stop()); assertThat(container.getContainers()).isNotEmpty();