|
|
@@ -0,0 +1,27 @@
|
|
|
+package com.zhongshu.iot.server.core.service.iotPlatform.impl;
|
|
|
+
|
|
|
+import com.github.microservice.net.ResultContent;
|
|
|
+import com.zhongshu.iot.server.core.domain.ExecuteAnnotationService;
|
|
|
+import com.zhongshu.iot.server.core.service.iotPlatform.PlatformTopic;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author TRX
|
|
|
+ * @date 2025/1/13
|
|
|
+ */
|
|
|
+@Component
|
|
|
+@ExecuteAnnotationService
|
|
|
+@Slf4j
|
|
|
+public class PlatFormAllTopic implements PlatformTopic {
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String topic() {
|
|
|
+ return "/platform/%s/#";
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public ResultContent<Object> action(String topic, String message) {
|
|
|
+ return ResultContent.buildSuccess();
|
|
|
+ }
|
|
|
+}
|
