Skip to content

M
my-flink-project
Commit 983d22c0 authored by 薄玉虎's avatar 薄玉虎
Browse files
Options

修改Mqtt频道号获取逻辑

parent d3b9546e
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
src/main/java/com/censoft/flink/StreamingJob.java
View file @ 983d22c0
...@@ -50,7 +50,7 @@ public class StreamingJob { ...@@ -50,7 +50,7 @@ public class StreamingJob {
//2、接收消息并将数据转化为流 //2、接收消息并将数据转化为流
//根据场景id 拼接对应的mqtt频道名称 //根据场景id 拼接对应的mqtt频道名称
// DataStream<AlgorithmPushDto> mqttStream = env.addSource(new MqttConsumer("/censoft/cpptest/10")); // DataStream<AlgorithmPushDto> mqttStream = env.addSource(new MqttConsumer("/censoft/cpptest/10"));
DataStream<AlgorithmPushDto> mqttStream = env.addSource(new MqttConsumer("/censoft/cpptest/" + (sceneId - 1))); DataStream<AlgorithmPushDto> mqttStream = env.addSource(new MqttConsumer("/censoft/cpptest/" + sceneId));
//3、进行处理 //3、进行处理
//3、0 更新场景在线时间 //3、0 更新场景在线时间
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment