优化

12 months ago · 08e14dc47b
parent 46cf209ddf
commit 08e14dc47b
1 changed files with 1 additions and 1 deletions
--- a/ms-biz/src/main/java/com/ms/biz/quque/Topic.java
+++ b/ms-biz/src/main/java/com/ms/biz/quque/Topic.java
@ -3,7 +3,7 @@ package com.ms.biz.quque;
 import com.ms.biz.tool.SystemTool;
 public class Topic {
-    public static final String TOPIC_DS_MESSAGE = "miaoshougoods_rsync_order";
+    public static final String TOPIC_DS_MESSAGE = "miaoshougoods_ds_message";
    public static String rebuild(String topic) {
        if (SystemTool.isDevEnv()) {
            return "local%" + topic;