Added configuration option of consumer subscription type.

Author: majusko

src/main/java/io/github/majusko/pulsar/annotation/PulsarConsumer.java

@@ -1,6 +1,7 @@
 package io.github.majusko.pulsar.annotation;
 
 import io.github.majusko.pulsar.constant.Serialization;
+import org.apache.pulsar.client.api.SubscriptionType;
 
 import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
@@ -13,4 +14,5 @@
     String topic();
     Class<?> clazz();
     Serialization serialization() default Serialization.JSON;
+    SubscriptionType subscriptionType() default SubscriptionType.Exclusive;
 }

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

@@ -42,6 +42,7 @@ private Consumer<?> subscribe(String name, ConsumerHolder holder) {
                 .consumerName("consumer-" + name)
                 .subscriptionName("subscription-" + name)
                 .topic(holder.getAnnotation().topic())
+                .subscriptionType(holder.getAnnotation().subscriptionType())
                 .messageListener((consumer, msg) -> {
                     try {
                         final Method method = holder.getHandler();