Merge pull request #8 from majusko/hotfix/adding-test-coverage

Hotfix/adding test coverage

Author: majusko

src/main/java/io/github/majusko/pulsar/collector/ConsumerCollector.java

@@ -2,6 +2,7 @@
 
 import io.github.majusko.pulsar.annotation.PulsarConsumer;
 import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.context.annotation.Configuration;
 import org.springframework.stereotype.Component;
 
 import java.util.Arrays;
@@ -10,7 +11,7 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.stream.Collectors;
 
-@Component
+@Configuration
 public class ConsumerCollector implements BeanPostProcessor {
 
     private Map<String, ConsumerHolder> consumers = new ConcurrentHashMap<>();
@@ -25,6 +26,8 @@ public Object postProcessBeforeInitialization(Object bean, String beanName) {
                 method -> beanClass.getName() + "#" + method.getName(),
                 method -> new ConsumerHolder(method.getAnnotation(PulsarConsumer.class), method, bean))));
 
+        System.out.println(consumers.toString());
+
         return bean;
     }
 

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

@@ -1,6 +1,7 @@
 package io.github.majusko.pulsar;
 
 import io.github.majusko.pulsar.collector.ConsumerCollector;
+import io.github.majusko.pulsar.collector.ConsumerHolder;
 import io.github.majusko.pulsar.constant.Serialization;
 import io.github.majusko.pulsar.consumer.ConsumerBuilder;
 import io.github.majusko.pulsar.producer.ProducerFactory;
@@ -26,7 +27,7 @@
 import java.util.Set;
 
 @SpringBootTest
-@Import(TestProducerConfiguration.class)
+@Import({TestProducerConfiguration.class, TestConsumerConfiguration.class})
 class PulsarJavaSpringBootStarterApplicationTests {
 
     @Autowired
@@ -58,17 +59,17 @@ void testConsumerRegistration1() throws Exception {
         Assertions.assertEquals("mock-topic", consumer.getTopic());
     }
 
-//    @Test
-//    void testConsumerRegistration2() throws Exception {
-//        final Class<TestConsumerConfiguration> clazz = TestConsumerConfiguration.class;
-//        final String descriptor = clazz.getName() + "#" + clazz.getDeclaredMethods()[0].getName();
-//        final ConsumerHolder consumerHolder = consumerCollector.getConsumer(descriptor).orElseThrow(Exception::new);
-//
-//        Assert.assertNotNull(consumerHolder);
-//        Assert.assertEquals("mock-topic", consumerHolder.getAnnotation().topic());
-//        Assert.assertEquals(TestConsumerConfiguration.class, consumerHolder.getBean().getClass());
-//        Assert.assertEquals("mockTheListener", consumerHolder.getHandler().getName());
-//    }
+    @Test
+    void testConsumerRegistration2() {
+        final Class<TestConsumerConfiguration> clazz = TestConsumerConfiguration.class;
+        final String descriptor = clazz.getName() + "#" + clazz.getMethods()[0].getName();
+        final ConsumerHolder consumerHolder = consumerCollector.getConsumer(descriptor).orElse(null);
+
+        Assertions.assertNotNull(consumerHolder);
+        Assertions.assertEquals("mock-topic", consumerHolder.getAnnotation().topic());
+        Assertions.assertEquals(TestConsumerConfiguration.class, consumerHolder.getBean().getClass());
+        Assertions.assertEquals("mockTheListener", consumerHolder.getHandler().getName());
+    }
 
     @Test
     void testProducerRegistration() {