Dispatch queue 'mqtt client' was not executing, (currently executing: '<not-dispatched>')

[eastpav]

I was encountered the error above when mqtt-client CallbackConnection runs in junit, a publish method would be triggering the error [org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)]. But, it works ok when the same code runs in normal.

The same thing will be happen when execute CallbackConnection.connect、CallbackConnection.listener and CallbackConnection.subscribe in order, In junit, subscribe method will trigger the error but in normal work ok.

Is some different from junit and normal? Thx

[sfiloveyou]

i have the same problem

[alexluojian]

this way may work. connection.getDispatchQueue().execute(()->{ connection.publish(topic, data, qos, retained, new Callback() { @Override public void onSuccess(Void value) { logger.debug("send success!"); } @Override public void onFailure(Throwable value) { logger.debug("send failed:", value); } }); });

[wrenchzc]

@alexluojian it works, but why?