Fixed jacoco init method injection and causing test failure.

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

@@ -27,7 +27,7 @@
 import java.util.Set;
 
 @SpringBootTest
-@Import(TestProducerConfiguration.class)
+@Import({TestProducerConfiguration.class, TestConsumerConfiguration.class})
 class PulsarJavaSpringBootStarterApplicationTests {
 
     @Autowired
@@ -60,10 +60,10 @@ void testConsumerRegistration1() throws Exception {
     }
 
     @Test
-    void testConsumerRegistration2() throws Exception {
+    void testConsumerRegistration2() {
         final Class<TestConsumerConfiguration> clazz = TestConsumerConfiguration.class;
-        final String descriptor = clazz.getName() + "#" + clazz.getDeclaredMethods()[0].getName();
-        final ConsumerHolder consumerHolder = consumerCollector.getConsumer(descriptor).orElseThrow(Exception::new);
+        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());