reverted

majusko · majusko · commit ba0171607f4f · 2020-08-15T19:29:02.000+02:00
diff --git a/src/main/java/io/github/majusko/pulsar/consumer/ConsumerBuilder.java b/src/main/java/io/github/majusko/pulsar/consumer/ConsumerBuilder.java
@@ -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()))

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ private void init() {`
`40`	`40`	`.collect(Collectors.toList());`
`41`	`41`	`}`
`42`	`42`
`43`		`- private Consumer subscribe(String name, ConsumerHolder holder) {`
	`43`	`+ private Consumer<?> subscribe(String name, ConsumerHolder holder) {`
`44`	`44`	`try {`
`45`	`45`	`return pulsarClient`
`46`	`46`	`.newConsumer(Schema.JSON(holder.getAnnotation().clazz()))`