Pavel Drankov
Pavel Drankov
+1 for this issue
@pc-jedi , but you can also use `asInstanceOf[JsArray]` approach, for example this code: ```scala val my_json = "[{\"kek\":1},{\"kek\":2}]" println(my_json.parseJson.asInstanceOf[JsArray].elements.size) ``` will produce `2`
@ctron, do you think we should have something like "timeout of CONNACK" right?
Hi @ctron , do you have a reproducer? It would helps
@abccbaandy, generally, I think you should reuse a single client for all the topics you have. In fact, MQTT client is single threaded, and in order to achieve a good...
And it would be also great if you would share your results/measurements afterwards
> btw, I put all these code in one verticle, is that good idea? Or should I put these handler in different verticle and access some global mqtt/redis client created...
In fact, it seems that you reached the MQTT 3.1.1 protocol limitation since you can have more than 65535 active packets: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/errata01/os/mqtt-v3.1.1-errata01-os-complete.html#_Toc442180838
@abccbaandy, I think that MQTT is fine for high concurrent messages system because you can easily scale horizontally and vertically. You just need to keep in mind that you are...
I think we can have a `readTimeout ` option, which can be applied not only for the MQTT connection phase(CONNECT & CONNACK).