Hylke van der Schaaf
Hylke van der Schaaf
@pstanton: I don't think they time out (I've not found a timeout mechanism in the code). ``` client = new MqttClient(SERVER_URI, CLIENT_ID); MqttConnectOptions options = new MqttConnectOptions(); options.setMaxInflight(1000); // Default...
Not just on H2, also on PostgreSQL.
I'm mainly interested in my changelogs not breaking, and your change breaks them both ways... Leaving the postition="x" in breaks things, removing the attribute also breaks things, since the signature...
The modifySql approach (I would not call it a solution) also has the problem that it is DB-specific. It has to be separately added for each current and future DBMS...
I've fixed quite a few memory leaks in the last few weeks, and released an unofficial Moquette version to Maven Central in the de.fraunhofer.iosb namespace: ``` de.fraunhofer.iosb.io.moquette moquette-broker 0.14.3 ```...
Good point, we need to change the documentation to point to maven central: https://repo1.maven.org/maven2/io/moquette/
Is there a way to discard/close a queue? For example when the client reconnects with cleanSession=true?
It seems your client is closing the connection without properly disconnecting from the server. Can't say much more than that without more details, and preferably a repeatable test-case.
This will be solved as part of the session handling work discussed in #608
If you mean the [MQTT 5.0 Shared Subscriptions](https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Toc3901250) feature, then no, not yet. MQTT 5.0 is on the TO-DO list.