2 Commits

Author SHA1 Message Date
7dfaac06e4 Fix: Recreate disconnected connections when being retrieved (#19) 2022-01-08 14:23:13 +01:00
9e69fb1e45 Use php-mqtt/client:^1.0 2021-01-10 19:50:26 +01:00
2 changed files with 7 additions and 1 deletions

View File

@ -22,7 +22,7 @@
"php": "^7.4|^8.0",
"illuminate/config": "~7.0|~8.0",
"illuminate/support": "~7.0|~8.0",
"php-mqtt/client": "v1.0.0-rc1"
"php-mqtt/client": "^1.0"
},
"require-dev": {
"squizlabs/php_codesniffer": "^3.5"

View File

@ -60,6 +60,12 @@ class ConnectionManager
$name = $this->defaultConnection;
}
// Remove the connection if it is in a disconnected state.
// Doing this instead of simply reconnecting ensures the caller will get a fresh connection.
if (array_key_exists($name, $this->connections) && !$this->connections[$name]->isConnected()) {
unset($this->connections[$name]);
}
if (!array_key_exists($name, $this->connections)) {
$this->connections[$name] = $this->createConnection($name);
}