for issue WeBankFinTech#64:add func to sub with tag

keranbingaa · Sep 12, 2022 · fbdc299 · fbdc299
1 parent 847174f
commit fbdc299
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java b/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java
@@ -155,6 +155,11 @@ public void subscribe(String topic) throws MQClientException {
         LOG.info("add subscription [{}] to consumer", topic);
     }
 
+    public void subscribe(String topic, String tag) throws MQClientException {
+        this.defaultMQPushConsumer.subscribe(topic, tag);
+        LOG.info("add subscription [{}] to consumer,tag = {}", topic, tag);
+    }
+
     public void unsubscribe(String topic) {
         unsubscribe(topic, true);
     }