Merge pull request #50 from majusko/hotfix/wrong-condition-in-tests

Fixed the test

Author: majusko

pom.xml

@@ -20,7 +20,7 @@
 		<maven.compiler.target>1.8</maven.compiler.target>
 		<maven.compiler.source>1.8</maven.compiler.source>
 		<apache.pulsar.client.version>2.6.1</apache.pulsar.client.version>
-		<testcontainers.version>1.14.3</testcontainers.version>
+		<testcontainers.version>1.15.0-rc2</testcontainers.version>
 		<junit-jupiter.version>5.7.0</junit-jupiter.version>
 		<awaitility.version>4.0.3</awaitility.version>
 		<reactor.core.version>3.4.0</reactor.core.version>

src/test/java/io/github/majusko/pulsar/PulsarJavaSpringBootStarterApplicationTests.java

@@ -21,11 +21,9 @@
 import org.testcontainers.junit.jupiter.Testcontainers;
 
 import java.time.Duration;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
+import java.util.*;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.stream.Collectors;
 
 import static org.awaitility.Awaitility.await;
 
@@ -84,13 +82,15 @@ void testConsumerRegistration1() throws Exception {
     @Test
     void testConsumerRegistration2() {
         final Class<TestConsumers> clazz = TestConsumers.class;
-        final String descriptor = clazz.getName() + clazz.getMethods()[0].getName();
-        final ConsumerHolder consumerHolder = consumerCollector.getConsumer(descriptor).orElse(null);
-
-        Assertions.assertNotNull(consumerHolder);
-        Assertions.assertEquals("topic-one", consumerHolder.getAnnotation().topic());
-        Assertions.assertEquals(TestConsumers.class, consumerHolder.getBean().getClass());
-        Assertions.assertEquals("topicOneListener", consumerHolder.getHandler().getName());
+        final List<ConsumerHolder> consumerHolders = Arrays.stream(clazz.getMethods())
+            .map($ -> consumerCollector.getConsumer(clazz.getName() + $.getName()).orElse(null))
+            .collect(Collectors.toList());
+
+        Assertions.assertNotNull(consumerHolders);
+        Assertions.assertTrue(consumerHolders.stream().anyMatch($ -> $.getAnnotation().topic().equals("topic-one")));
+        Assertions.assertTrue(consumerHolders.stream().anyMatch($ -> $.getAnnotation().topic().equals("topic-for-error")));
+        Assertions.assertTrue(consumerHolders.stream().anyMatch($ -> $.getBean().getClass().equals(TestConsumers.class)));
+        Assertions.assertTrue(consumerHolders.stream().anyMatch($ -> $.getHandler().getName().equals("topicOneListener")));
     }
 
     @Test