From 5688e9adb709a253e1ce69b510457b9c88a645a9 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 16 Sep 2021 16:39:18 +0800 Subject: [PATCH] screnn_api特殊设备实体类修改,走航车实时websocket,manage设备补偿 --- screen-common/src/main/java/com/moral/constant/KafkaConstants.java | 32 +++++++++++++++++++++++++++++--- 1 files changed, 29 insertions(+), 3 deletions(-) diff --git a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java index 534ff0c..3f58d3c 100644 --- a/screen-common/src/main/java/com/moral/constant/KafkaConstants.java +++ b/screen-common/src/main/java/com/moral/constant/KafkaConstants.java @@ -18,8 +18,34 @@ public static final String TOPIC_SECOND = "second_data"; /** - * ��������������������������������������������������� + * ������������������������ */ - public static final String TOPIC_SECOND_SPECIAL = "second_data_special"; - + public static final String UAV_TOPIC_SECOND = "uav_second_data"; + + /* + * ��������������������������� + * */ + public static final String CRUISER_TOPIC_SECOND = "cruiser_second_data"; + + /* + * ��������������������������� + * */ + public static final String CRUISER_TOPIC_MINUTE = "cruiser_minute_data"; + + /* + * ��������������������������� + * */ + public static final String CRUISER_TOPIC_HOUR = "cruiser_hour_data"; + + + /** + * ��������������������������� + */ + public static final String GROUP_INSERT = "insert"; + + /** + * ��������������������������������� + */ + public static final String GROUP_STATE = "state"; + } -- Gitblit v1.8.0