Struct MqttBroker 

pub struct MqttBroker { /* private fields */ }

MQTT broker implementation

Implementations

impl MqttBroker

pub fn new(config: MqttConfig, _spec_registry: Arc<MqttSpecRegistry>) -> Self

pub async fn client_connect( &self, client_id: &str, clean_session: bool, ) -> Result<(), Box<dyn Error>>

Handle client connection with session management

pub async fn client_disconnect( &self, client_id: &str, ) -> Result<(), Box<dyn Error>>

Handle client disconnection with session persistence

pub async fn client_subscribe( &self, client_id: &str, topics: Vec<(String, u8)>, ) -> Result<(), Box<dyn Error>>

Subscribe client to topics with session persistence

pub async fn client_unsubscribe( &self, client_id: &str, filters: Vec<String>, ) -> Result<(), Box<dyn Error>>

Unsubscribe client from topics

pub fn config(&self) -> &MqttConfig

Get broker configuration (for testing)

pub async fn get_active_topics(&self) -> Vec<String>

Get list of active topics (subscription filters and retained topics)

pub async fn get_connected_clients(&self) -> Vec<String>

Get list of connected clients

pub async fn get_client_info(&self, client_id: &str) -> Option<ClientSession>

Get client information

pub async fn disconnect_client( &self, client_id: &str, ) -> Result<(), Box<dyn Error>>

Disconnect a client

pub async fn get_topic_stats(&self) -> TopicStats

Get topic statistics

pub async fn next_packet_id(&self) -> u16

Generate next packet ID

pub async fn handle_publish( &self, client_id: &str, topic: &str, payload: Vec<u8>, qos: u8, retain: bool, ) -> Result<(), Box<dyn Error>>

pub async fn publish_with_qos( &self, client_id: &str, topic: &str, payload: Vec<u8>, qos: u8, retain: bool, ) -> Result<(), Box<dyn Error>>

Publish a message with QoS handling but skip fixture lookup (used for fixture responses)

pub async fn update_metrics(&self)

Update Prometheus metrics with current broker statistics