Struct MqttClientConfig

pub struct MqttClientConfig<S> {
    pub connection: MqttOptions,
    pub settings: ClientSettings,
    /* private fields */
}

Configuration for MQTT client creation

Fields

connection: MqttOptions

Underlying MQTT connection options (from rumqttc)

settings: ClientSettings

Client-level performance and behavior settings

Implementations

impl<S> MqttClientConfig<S>

pub fn new(client_id: &str, host: &str, port: u16) -> MqttClientConfig<S>

Create config with default settings

pub fn from_url(url: &str) -> Result<MqttClientConfig<S>, OptionError>

Parse configuration from MQTT URL

Supports: tcp://, mqtt://, ssl://, mqtts://, ws://, wss://

pub fn localhost(client_id: &str) -> MqttClientConfig<S>

Create config for localhost:1883

pub fn with_last_will<T>( &mut self, last_will: TypedLastWill<T>, ) -> Result<&mut MqttClientConfig<S>, MqttClientError>

where S: MessageSerializer<T>,

Configure Last Will and Testament message

The Last Will message will be published by the broker if this client disconnects unexpectedly. Payload is serialized immediately using the configured serializer type.

Example

let mut config = MqttClientConfig::<BincodeSerializer>::new("client", "broker", 1883);

// Create last will manually (in real code, use generated methods from #[mqtt_topic])
let last_will = TypedLastWill {
    topic: "devices/123/status".to_string(),
    payload: "offline".to_string(),
    qos: QoS::AtLeastOnce,
    retain: true,
};

config.with_last_will(last_will)?;

Errors

Returns MqttClientError::Serialization if payload serialization fails.

Trait Implementations

impl<S> Clone for MqttClientConfig<S>

where S: Clone,

fn clone(&self) -> MqttClientConfig<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S> Debug for MqttClientConfig<S>

where S: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.