| .. | .. |
|---|
| 149 | 149 | client.onAutoReconnect = _onAutoReconnect; |
|---|
| 150 | 150 | client.onAutoReconnected = _onAutoReconnected; |
|---|
| 151 | 151 | |
|---|
| 152 | | - // Persistent session (cleanSession = false) for offline message queuing |
|---|
| 152 | + // Persistent session: broker queues QoS 1 messages while client is offline |
|---|
| 153 | 153 | final connMessage = MqttConnectMessage() |
|---|
| 154 | 154 | .withClientIdentifier(clientId) |
|---|
| 155 | | - .authenticateAs('pailot', config.mqttToken ?? '') |
|---|
| 156 | | - .startClean(); // Use clean session for now; persistent sessions require broker support |
|---|
| 157 | | - |
|---|
| 158 | | - // For persistent sessions, replace startClean() with: |
|---|
| 159 | | - // .withWillQos(MqttQos.atLeastOnce); |
|---|
| 160 | | - // and remove startClean() |
|---|
| 155 | + .authenticateAs('pailot', config.mqttToken ?? ''); |
|---|
| 161 | 156 | |
|---|
| 162 | 157 | client.connectionMessage = connMessage; |
|---|
| 163 | 158 | |
|---|
