bug fix:getSubscribers (#751)

WeBankBlockchain · Mar 16, 2021 · dbf75ce · dbf75ce
1 parent 25890c8
commit dbf75ce
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/weevent-file/src/main/java/com/webank/weevent/file/inner/AMOPChannel.java b/weevent-file/src/main/java/com/webank/weevent/file/inner/AMOPChannel.java
@@ -631,7 +631,9 @@ public static boolean matchTopic(String pattenTopic, String topic) {
             return true;
         }
         //verity topic
-        String verifyTopicPre = TopicManager.verifyChannelPrefix + TopicManager.topicNeedVerifyPrefix + topic;
+        StringBuilder sb = new StringBuilder();
+        sb.append(TopicManager.verifyChannelPrefix).append(TopicManager.topicNeedVerifyPrefix).append(topic).append('_');
+        String verifyTopicPre = sb.toString();
         if (pattenTopic.startsWith(verifyTopicPre)) {
             return true;
         }