提交 600d113d authored 作者: wangqiang's avatar wangqiang

rpc sub

上级 85b9dd81
...@@ -62,6 +62,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -62,6 +62,7 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
@Value(value = "${apq.url.device_info}") @Value(value = "${apq.url.device_info}")
private String deviceInfo; private String deviceInfo;
//private static final String GATEWAY_RPC_TOPIC = "gateway/rpc"; //private static final String GATEWAY_RPC_TOPIC = "gateway/rpc";
//private static final String GATEWAY_ATTRIBUTES_TOPIC = "gateway/attrs"; //private static final String GATEWAY_ATTRIBUTES_TOPIC = "gateway/attrs";
//private static final String GATEWAY_TELEMETRY_TOPIC = "gateway/telemetry"; //private static final String GATEWAY_TELEMETRY_TOPIC = "gateway/telemetry";
...@@ -113,6 +114,8 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -113,6 +114,8 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
@Autowired @Autowired
private NioEventLoopGroup nioEventLoopGroup; private NioEventLoopGroup nioEventLoopGroup;
@Resource
private RemoteControlController remoteControlController;
public MqttServiceImpl(PcCoreConfiguration configuration, Consumer<String> extensionsConfigListener) { public MqttServiceImpl(PcCoreConfiguration configuration, Consumer<String> extensionsConfigListener) {
this.configuration = configuration; this.configuration = configuration;
...@@ -352,10 +355,6 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall ...@@ -352,10 +355,6 @@ public class MqttServiceImpl implements MqttService, MqttHandler, MqttClientCall
} }
} }
@Resource
private RemoteControlController remoteControlController;
private void onRpcCommand(String message) { private void onRpcCommand(String message) {
JsonNode payload = fromString(message); JsonNode payload = fromString(message);
MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder().requestId(payload.get("id").asInt()) MqttRpcDataMessage mqttRpcDataMessage = MqttRpcDataMessage.builder().requestId(payload.get("id").asInt())
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论