From 50724aa7fda10d8d3f506b138c336d2bece4e839 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Thu, 9 Aug 2012 23:19:07 +0200 Subject: [PATCH] Minor change --- parser/src/main/java/org/dna/mqtt/moquette/client/Client.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java b/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java index 0714b203..36923d6b 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/client/Client.java @@ -233,7 +233,7 @@ public final class Client { throw new SubscribeException(ex); } - //TODO register the publishCallback in some registry to be notified + //register the publishCallback in some registry to be notified m_subscribersList.put(topic, publishCallback); //wait for the SubAck @@ -255,7 +255,7 @@ public final class Client { updatePinger(); - //TODO check the ACK messageID + //TODO check the ACK messageID only for QoS 1 and 2 } /**