|
|
|
@ -17,7 +17,7 @@
|
|
|
|
|
|
|
|
|
|
// written by Sascha Steinbiss <sascha@steinbiss.name>
|
|
|
|
|
|
|
|
|
|
use super::mqtt::{MQTTState, MQTTTransaction};
|
|
|
|
|
use super::mqtt::MQTTTransaction;
|
|
|
|
|
use crate::jsonbuilder::{JsonBuilder, JsonError};
|
|
|
|
|
use crate::mqtt::mqtt_message::{MQTTOperation, MQTTSubscribeTopicData};
|
|
|
|
|
use crate::mqtt::parser::FixedHeader;
|
|
|
|
@ -298,7 +298,7 @@ fn log_mqtt(tx: &MQTTTransaction, flags: u32, js: &mut JsonBuilder) -> Result<()
|
|
|
|
|
|
|
|
|
|
#[no_mangle]
|
|
|
|
|
pub unsafe extern "C" fn rs_mqtt_logger_log(
|
|
|
|
|
_state: &mut MQTTState, tx: *mut std::os::raw::c_void, flags: u32, js: &mut JsonBuilder,
|
|
|
|
|
tx: *mut std::os::raw::c_void, flags: u32, js: &mut JsonBuilder,
|
|
|
|
|
) -> bool {
|
|
|
|
|
let tx = cast_pointer!(tx, MQTTTransaction);
|
|
|
|
|
log_mqtt(tx, flags, js).is_ok()
|
|
|
|
|