From fbdc299879d9c0d86dd6f1a9410a5263f5924663 Mon Sep 17 00:00:00 2001
From: keranbingaa <397294722@qq.com>
Date: Mon, 12 Sep 2022 09:57:20 +0800
Subject: [PATCH] for issue #64:add func to sub with tag

---
 .../com/webank/defibus/consumer/DeFiBusPushConsumer.java     | 5 +++++
 1 file changed, 5 insertions(+)

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
index 4130d66..07cb3e4 100644
--- 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);
     }