fix: 修复RocketMQ topic名称非法字符问题
RocketMQ topic 只允许 ^[%|a-zA-Z0-9_-]+$ 字符,不支持 `.` IoT 模块 Topic 变更: - integration.device.status → integration-device-status - integration.device.property → integration-device-property - integration.device.event → integration-device-event Ops 模块 Topic 变更: - ops.order.create → ops-order-create - ops.order.arrive → ops-order-arrive - ops.order.complete → ops-order-complete - ops.order.audit → ops-order-audit - ops.order.confirm → ops-order-confirm Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
@@ -12,26 +12,26 @@ public interface CleanOrderTopics {
|
||||
/**
|
||||
* 保洁工单创建事件
|
||||
*/
|
||||
String ORDER_CREATE = "ops.order.create";
|
||||
String ORDER_CREATE = "ops-order-create";
|
||||
|
||||
/**
|
||||
* 保洁工单到岗事件
|
||||
*/
|
||||
String ORDER_ARRIVE = "ops.order.arrive";
|
||||
String ORDER_ARRIVE = "ops-order-arrive";
|
||||
|
||||
/**
|
||||
* 保洁工单完成事件
|
||||
*/
|
||||
String ORDER_COMPLETE = "ops.order.complete";
|
||||
String ORDER_COMPLETE = "ops-order-complete";
|
||||
|
||||
/**
|
||||
* 保洁工单审计事件
|
||||
*/
|
||||
String ORDER_AUDIT = "ops.order.audit";
|
||||
String ORDER_AUDIT = "ops-order-audit";
|
||||
|
||||
/**
|
||||
* 保洁工单确认事件(按键确认)
|
||||
*/
|
||||
String ORDER_CONFIRM = "ops.order.confirm";
|
||||
String ORDER_CONFIRM = "ops-order-confirm";
|
||||
|
||||
}
|
||||
|
||||
@@ -14,21 +14,21 @@ public class IntegrationTopics {
|
||||
* <p>
|
||||
* 用于发布设备上线/离线状态变更事件
|
||||
*/
|
||||
public static final String DEVICE_STATUS = "integration.device.status";
|
||||
public static final String DEVICE_STATUS = "integration-device-status";
|
||||
|
||||
/**
|
||||
* 设备属性变更 Topic
|
||||
* <p>
|
||||
* 用于发布设备属性变更事件
|
||||
*/
|
||||
public static final String DEVICE_PROPERTY = "integration.device.property";
|
||||
public static final String DEVICE_PROPERTY = "integration-device-property";
|
||||
|
||||
/**
|
||||
* 设备事件上报 Topic
|
||||
* <p>
|
||||
* 用于发布设备事件(SOS、按键等)
|
||||
*/
|
||||
public static final String DEVICE_EVENT = "integration.device.event";
|
||||
public static final String DEVICE_EVENT = "integration-device-event";
|
||||
|
||||
private IntegrationTopics() {
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user