Fixed generics type problem.

Author: majusko

src/main/java/io/github/majusko/pulsar/consumer/ConsumerBuilder.java

@@ -26,7 +26,7 @@ public class ConsumerBuilder {
     private final ConsumerCollector consumerCollector;
     private final PulsarClient pulsarClient;
 
-    private List<Consumer<?>> consumers;
+    private List<Consumer> consumers;
 
     public ConsumerBuilder(ConsumerCollector consumerCollector, PulsarClient pulsarClient) {
         this.consumerCollector = consumerCollector;
@@ -40,7 +40,7 @@ private void init() {
             .collect(Collectors.toList());
     }
 
-    private Consumer<?> subscribe(String name, ConsumerHolder holder) {
+    private Consumer subscribe(String name, ConsumerHolder holder) {
         try {
             return pulsarClient
                 .newConsumer(Schema.JSON(holder.getAnnotation().clazz()))
@@ -66,7 +66,7 @@ private Consumer<?> subscribe(String name, ConsumerHolder holder) {
         }
     }
 
-    public List<Consumer<?>> getConsumers() {
+    public List<Consumer> getConsumers() {
         return consumers;
     }
 

src/main/java/io/github/majusko/pulsar/producer/ProducerCollector.java

@@ -20,7 +20,7 @@ public class ProducerCollector implements BeanPostProcessor {
 
     private final PulsarClient pulsarClient;
 
-    private final Map<String, Producer<?>> producers = new ConcurrentHashMap<>();
+    private final Map<String, Producer> producers = new ConcurrentHashMap<>();
 
     public ProducerCollector(PulsarClient pulsarClient) {
         this.pulsarClient = pulsarClient;
@@ -61,7 +61,7 @@ private <T> Schema<?> getSchema(ProducerHolder holder) throws RuntimeException {
         throw new ProducerInitException("Unknown producer schema.");
     }
 
-    Map<String, Producer<?>> getProducers() {
+    Map<String, Producer> getProducers() {
         return producers;
     }
 }

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

@@ -68,7 +68,7 @@ void testProducerSendMethod() throws PulsarClientException {
 
     @Test
     void testConsumerRegistration1() throws Exception {
-        final List<Consumer<?>> consumers = consumerBuilder.getConsumers();
+        final List<Consumer> consumers = consumerBuilder.getConsumers();
 
         Assertions.assertEquals(2, consumers.size());