Skip to content

Commit

Permalink
stop using node
Browse files Browse the repository at this point in the history
  • Loading branch information
jr1221 committed Dec 20, 2024
1 parent 85bee49 commit 427ad42
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions scylla-server/src/mqtt_processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -235,11 +235,9 @@ impl MqttProcessor {
return None;
};

// get the node and datatype from the topic extracted at the beginning
// get the node from the topic extracted at the beginning
let node = split.0;

let data_type = String::from(split.1);

// extract the unix time
// levels of time priority
// - A: The time packaged in the protobuf, to microsecond precision
Expand Down Expand Up @@ -301,7 +299,7 @@ impl MqttProcessor {

Some(ClientData {
run_id: crate::RUN_ID.load(Ordering::Relaxed),
name: data_type,
name: topic.to_string(),
unit: data.unit,
values: data.values,
timestamp: unix_clean,
Expand Down

0 comments on commit 427ad42

Please sign in to comment.