Hi Isuru, We can look at the asynchronous option as well.As this asynchronous client is non-blocking interface where methods return before the requested operation has completed.IMO If we use the asynchronous mode we need to tackle with the return delivery token to guaranteed the message delivery. In pahu samples there is a some examples with the asynchronous methods. SampleAsyncCallBack.java SampleAsyncWait.java
In there doing is getting the MqttToken and waiting for that operation to complete. IMqttToken conToken = client.connect(conOpt,null,null); conToken.waitForCompletion(); I guess we also need to implement sort of a thing for guaranteed message delivery when using the asynchronous mode. Thanks, Gayan On Tue, Nov 11, 2014 at 10:09 AM, Isuru Haththotuwa <isu...@apache.org> wrote: > Hi devs, > > I experienced $subject again intermittently for the past day. I'm looking > in to this. > > One thing that I noted is that we have used a blocking MQTT client > implementation to publish and subscribe to the MB. There is a asynchronous > version [1] as well, which is more powerful than the blocking client. AFAIU > non-blocking client can be more suitable for a distributed setup such as > Stratos. Were there are specific reason to use the blocking client? > > [1]. > http://www.eclipse.org/paho/files/javadoc/org/eclipse/paho/client/mqttv3/MqttAsyncClient.html > > > -- > Thanks and Regards, > > Isuru H. > +94 716 358 048* <http://wso2.com/>* > > > -- Gayan Gunarathne Technical Lead WSO2 Inc. (http://wso2.com) email : gay...@wso2.com | mobile : +94 766819985