Browse Source

feature: 修改 rest 回调 topic 兼容历史数据

Walker 1 year ago
parent
commit
11d47db894

+ 3 - 3
src/main/java/com/ywt/biz/common/constant/KafkaTopicsConstants.java

@@ -35,14 +35,14 @@ public class KafkaTopicsConstants {
     /**
      * 眼镜店退款回调
      */
-    public static final String REFUNDCALLBACK_GLASSESAPISERVICE_REST_MSG = "refundCallback.GlassesApiService.rest.msg";
+    public static final String REFUNDCALLBACK_GLASSESAPISERVICE_REST_MSG = "rest://com.ywt.GlassesApiService/mg/order/refundCallback";
     /**
      * 营养餐微信自动退款回调
      */
-    public static final String AUTOWECHATREFUNDCALLBACK_NUTRIMEALAPISERVICE_REST_MSG = "autoWeChatRefundCallback.NutrimealApiService.rest.msg";
+    public static final String AUTOWECHATREFUNDCALLBACK_NUTRIMEALAPISERVICE_REST_MSG = "rest://com.ywt.NutrimealApiService/mealOrder/autoWechatRefundCallback";
     /**
      * 营养餐退款回调
      */
-    public static final String REFUNDCALLBACK_NUTRIMEALAPISERVICE_REST_MSG = "refundCallback.NutrimealApiService.rest.msg";
+    public static final String REFUNDCALLBACK_NUTRIMEALAPISERVICE_REST_MSG = "rest://com.ywt.NutrimealApiService/mealOrder/refundCallback";
 
 }