anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed a test

Browse Source
This commit is contained in:
selva.andre
2012-09-05 20:01:10 +02:00
parent 1dafa02f53
commit ff5c60a608
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
-1
View File
@@ -402,7 +402,6 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
//TODO by now it handles only QoS 0 messages //TODO by now it handles only QoS 0 messages
for (int i = 0; i < msg.subscriptions().size(); i++) { for (int i = 0; i < msg.subscriptions().size(); i++) {
ackMessage.addType(QOSType.MOST_ONE); ackMessage.addType(QOSType.MOST_ONE);
ackMessage.addType(QOSType.LEAST_ONE);
} }
LOG.info("replying with SubAct to MSG ID " + msg.getMessageID()); LOG.info("replying with SubAct to MSG ID " + msg.getMessageID());
session.write(ackMessage); session.write(ackMessage);