fixed: dont use DEFAULT

sweipei · Mar 6, 2019 · d32aafe · d32aafe
1 parent 576ae41
commit d32aafe
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/qmq-api/src/main/java/qunar/tc/qmq/SubscribeParam.java b/qmq-api/src/main/java/qunar/tc/qmq/SubscribeParam.java
@@ -23,8 +23,6 @@
  * @author yiqun.fan create on 17-11-2.
  */
 public class SubscribeParam {
-    public static final SubscribeParam DEFAULT = new SubscribeParam(false, false, TagType.NO_TAG, Collections.<String>emptySet());
-
     private final boolean consumeMostOnce;
     private final TagType tagType;
     private boolean isBroadcast;
@@ -61,7 +59,7 @@ public static final class SubscribeParamBuilder {
         private boolean consumeMostOnce = false;
         private Set<String> tags = Collections.emptySet();
         private TagType tagType = TagType.NO_TAG;
-        private boolean isBroadcast;
+        private boolean isBroadcast = false;
 
         public SubscribeParam create() {
             return new SubscribeParam(consumeMostOnce, isBroadcast, tagType, tags);

diff --git a/qmq-client/src/main/java/qunar/tc/qmq/consumer/MessageConsumerProvider.java b/qmq-client/src/main/java/qunar/tc/qmq/consumer/MessageConsumerProvider.java
@@ -86,7 +86,7 @@ public void init() {
 
     @Override
     public ListenerHolder addListener(String subject, String consumerGroup, MessageListener listener, Executor executor) {
-        return addListener(subject, consumerGroup, listener, executor, SubscribeParam.DEFAULT);
+        return addListener(subject, consumerGroup, listener, executor, new SubscribeParam.SubscribeParamBuilder().create());
     }
 
     @Override