瀏覽代碼

fix 新增kafka配置

daiyihua 1 年之前
父節點
當前提交
5fcc11a6e3

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

@@ -16,9 +16,12 @@ public class KafkaRecordParamConstants {
     public static final String LOGID_SENDMPTEMPLATEMESSAGEBYLOGID_WECHATMESSAGESERVICE="logId";
     public static final String LOGID_SENDMPSUBSCRIBEMESSAGEBYLOGID_WECHATMESSAGESERVICE="logId";
     public static final String USERID_SYNCMEDCARD_USERSERVICE="userId";
-
-
-
+    public static final String ARTICLEID_CONVERTVIDEOCALLBACK_ARTICLESERVICE = "articleId";
+    public static final String NEWVIDEOURL_CONVERTVIDEOCALLBACK_ARTICLESERVICE = "newVideoUrl";
+    public static final String STATUS_CONVERTVIDEOCALLBACK_ARTICLESERVICE = "status";
+    public static final String REMARK_CONVERTVIDEOCALLBACK_ARTICLESERVICE = "remark";
+    public static final String VIDEOURL_PUBLISHVIDEOCALLBACK_VIDEOSERVICE = "videoUrl";
+    public static final String FILENAME_PUBLISHVIDEOCALLBACK_VIDEOSERVICE = "fileName";
 
 
 }

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

@@ -51,4 +51,13 @@ public class KafkaTopicsConstants {
      */
     public static final String SYNCMEDCARD_USERSERVICEPROVIDER_RPC_INTERNETHOSPITAL = "syncMedCard.UserServiceProvider.rpc.internethospital";
 
+    /**
+     * 转码视频回调接口
+     */
+    public static final String CONVERTVIDEOCALLBACK_ARTICLESERVICEPROVIDER_RPC_INTERNETHOSPITAL = "convertVideoCallback.ArticleServiceProvider.rpc.internethospital";
+    /**
+     * 公共视频回调
+     */
+    public static final String PUBLISHVIDEOCALLBACK_VIDEOPROVIDER_RPC_BASESERVICE = "publishVideoCallback.VideoProvider.rpc.baseservice";
+
 }