receive all the times
NoPerfectName opened this issue · 1 comments
NoPerfectName commented
I use the blocking connection api ,when I receive the message and then "message.ack()",but I can receive the message again on the next time,what is wrong?
connection = mqtt.blockingConnection();
connection.connect();
connection.subscribe(topics);
while (true) {
Message message = connection.receive();
String receiveMessage = String.valueOf(UTF8Buffer.utf8(message.getPayloadBuffer()));
System.out.println(receiveMessage);
message.ack();
}
Vivien- commented
Hi, how did you solve this issue ?
I use the future API but am facing the same issue : I can only fetch 1 notification but there is not really a way to subscribe to any notification from a topic ?