// 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;
#[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()
if (state) {
MQTTTransaction *tx = AppLayerParserGetTx(f->proto, ALPROTO_MQTT, state, tx_id);
if (tx) {
- return rs_mqtt_logger_log(state, tx, MQTT_DEFAULTS, js);
+ return rs_mqtt_logger_log(tx, MQTT_DEFAULTS, js);
}
}
return TM_ECODE_FAILED;
}
- if (!rs_mqtt_logger_log(state, tx, thread->mqttlog_ctx->flags, js))
+ if (!rs_mqtt_logger_log(tx, thread->mqttlog_ctx->flags, js))
goto error;
OutputJsonBuilderBuffer(js, thread->ctx);