mqtt: rustfmt mqtt.rs

diff --git a/rust/src/mqtt/mqtt.rs b/rust/src/mqtt/mqtt.rs
index 9044cd0b1fa1121c2349015c6d32c2d452261de4..6149ce5982a6cff188fa739fb5a227fb8218d63e 100644 (file)
--- a/rust/src/mqtt/mqtt.rs
+++ b/rust/src/mqtt/mqtt.rs
@@ -621,7 +621,9 @@ impl MQTTState {
         self.transactions.push_back(tx);
     }
 
-    fn mqtt_hdr_and_data_frames(&mut self, flow: *const Flow, stream_slice: &StreamSlice, input: &MQTTMessage) {
+    fn mqtt_hdr_and_data_frames(
+        &mut self, flow: *const Flow, stream_slice: &StreamSlice, input: &MQTTMessage,
+    ) {
         let hdr = stream_slice.as_slice();
         //MQTT payload has a fixed header of 2 bytes
         let _mqtt_hdr = Frame::new(flow, stream_slice, hdr, 2, MQTTFrameType::Header as u8);
@@ -831,4 +833,4 @@ pub unsafe extern "C" fn rs_mqtt_register_parser(cfg_max_msg_len: u32) {
     } else {
         SCLogDebug!("Protocol detector and parser disabled for MQTT.");
     }
-}
\ No newline at end of file
+}