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);
     }