B4J Question jMQTT set message queue size

[Coldrestart]

Hello everyone,

I have a question about the jMQTT library.
Is it possible to configure the option "max_queued_messages_set(self, queue_size)" ?

jMQTT - Official MQTT client

Implementation of MQTT client based on the Paho open source project: http://www.eclipse.org/paho/ See this tutorial for more information: https://www.b4x.com/android/forum/threads/iot-mqtt-protocol.59471/ jMQTT.zip holds the older version, which is compatible with B4A. B4J_Only_jMQTT.zip -...

www.b4x.com

My system runs on a PC, where sometimes the internet connection is lost for a long time.
I like that the messages are buffered, but when a long internet interruption occurs, I want to prevent consuming all ram memory.

Eclipse Paho | The Eclipse Foundation

The Eclipse Foundation - home to a global community, the Eclipse IDE, Jakarta EE and over 415 open source projects, including runtimes, tools and frameworks.

www.eclipse.org

My second question / wish, is it possible to support MQTT v5?

Thanks in advance,
Coldrestart.

 

[teddybear]

Hello everyone,

I have a question about the jMQTT library.
Is it possible to configure the option "max_queued_messages_set(self, queue_size)" ?

jMQTT - Official MQTT client

Implementation of MQTT client based on the Paho open source project: http://www.eclipse.org/paho/ See this tutorial for more information: https://www.b4x.com/android/forum/threads/iot-mqtt-protocol.59471/ jMQTT.zip holds the older version, which is compatible with B4A. B4J_Only_jMQTT.zip -...

www.b4x.com

My system runs on a PC, where sometimes the internet connection is lost for a long time.
I like that the messages are buffered, but when a long internet interruption occurs, I want to prevent consuming all ram memory.

Eclipse Paho | The Eclipse Foundation

The Eclipse Foundation - home to a global community, the Eclipse IDE, Jakarta EE and over 415 open source projects, including runtimes, tools and frameworks.

www.eclipse.org

My second question / wish, is it possible to support MQTT v5?

Thanks in advance,
Coldrestart.

Why do you want to config the max_queued? when the internet is disconnected, the event mqtt_disconnected is raised and you can not publish messages. if you would like to buffer the messages, you can save them into a file and resend them after the internet is connected

 

[Coldrestart]

Ok, I thought that the MQTT client lib would do the buffering task.

Thanks for helping out, I will make a test setup to understand it better.

 

[Erel]

Check CloudKVS for a possible solution for such cases where the device isn't always online: https://www.b4x.com/android/forum/threads/b4x-cloudkvs-synchronized-key-value-store.63536/#content