use idworker::IdWorkerError;
use rumqttc::ClientError;
use thiserror::Error;
#[derive(Error, Debug)]
pub enum MqttError {
#[error("MQTT请求失败: {0}")]
Request(#[from] ClientError),
#[error("MQTT消息处理失败: {0}")]
Handle(String),
#[error("ID工作者错误: {0}")]
IdWorker(#[from] IdWorkerError),
}