don't leak policies

This commit is contained in:
Michael Zanetti 2018-11-28 12:20:16 +01:00
parent 8df5d75dd1
commit 7b483bb087

View File

@ -111,6 +111,11 @@ MqttClient *MqttProviderImplementation::createInternalClient(const DeviceId &dev
client->setPassword(policy.password);
client->setAutoReconnect(false);
connect(client, &MqttClient::destroyed, this, [this, clientId]() {
qCDebug(dcMqtt) << "Internal MQTT client destroyed. Removing policy";
m_broker->removePolicy(clientId);
});
if (preferredConfig.address == QHostAddress::Any
|| preferredConfig.address == QHostAddress::AnyIPv4
|| preferredConfig.address == QHostAddress::LocalHost) {