diff --git a/aimdb-mqtt-connector/src/native.rs b/aimdb-mqtt-connector/src/native.rs index af67fe04..f45ad04f 100644 --- a/aimdb-mqtt-connector/src/native.rs +++ b/aimdb-mqtt-connector/src/native.rs @@ -269,8 +269,8 @@ impl Source for MqttEventLoopSource { loop { match self.event_loop.poll().await { Ok(Event::Incoming(Packet::Publish(publish))) => { - let topic = publish.topic.clone(); let payload: Payload = Arc::from(publish.payload.as_ref()); + let topic = publish.topic; log_debug!( "Received MQTT message on topic '{}' ({} bytes)",