When Qos is AT_MOST_ONCE , connection.publish() is blocked all the time.
I found class CallbackConnection line 699.
private void send(Acked command, Callback cb) {
short id = 0;
//if(command.qos() != QoS.AT_MOST_ONCE) {
id = getNextMessageId();
command.messageId(id);
// }
send(new Request(id, command.encode(), cb));
}
remove the "//", problem solved。
Looking forward to your reply,thank you。
When Qos is AT_MOST_ONCE , connection.publish() is blocked all the time.
I found class CallbackConnection line 699.
remove the "//", problem solved。
Looking forward to your reply,thank you。