Hi All, The following is the status of the MQTT Moquette library integration with MB 3.0.0,
~ Library was revamped to fit in with the Andes kernel. Attached diagram depicts how the messages are flowed between the components at a high level. ~ Implemented a MQTT client for subscription and publishing. ~ Also the Moquette library was patched, the default behaviour of the library did not support multiple subscribers to receive a published message. That was due to a bug which had a common ByteBuffer shared between concurrently accessing subscriber connections. The issue was fixed by cloning ByteBuffer instances per subscriber. Note that the wrapped array element was not duplicated or changed. The implemented code and artefacts could be found in [1]. Will commit the code once reviewed. To-Dos ~Need to package the dependencies. - Need to prepare test cases that would cover all the aspects described in the MQTT spec. - Need to test MQTT use cases in a cluster. - Need to load test and perform a long running test. - Need to discuss on the UI aspects. Please do let know if there're amendments to be made. Thanks, Pamod [1] https://svn.wso2.org/repos/wso2/scratch/pamod/mqtt_wrok/ -- *Pamod Sylvester * * Software Engineer * Integration Technologies Team, WSO2 Inc.; http://wso2.com email: [email protected] cell: +94 77 7779495
<<attachment: MQTT Message Flow.png>>
_______________________________________________ Architecture mailing list [email protected] https://mail.wso2.org/cgi-bin/mailman/listinfo/architecture
