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?