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

Added to the server's MQTTHandler the handling of PINGREQ message

Browse Source
This commit is contained in:
selva.andre
2012-08-10 19:35:43 +02:00
parent 8e3f83403f
commit 732031a624
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
+3
View File
@@ -13,6 +13,7 @@ import org.dna.mqtt.moquette.proto.messages.AbstractMessage.QOSType;
import org.dna.mqtt.moquette.proto.messages.ConnAckMessage;
import org.dna.mqtt.moquette.proto.messages.ConnectMessage;
import org.dna.mqtt.moquette.proto.messages.DisconnectMessage;
import org.dna.mqtt.moquette.proto.messages.PingRespMessage;
import org.dna.mqtt.moquette.proto.messages.PublishMessage;
import org.dna.mqtt.moquette.proto.messages.SubAckMessage;
import org.dna.mqtt.moquette.proto.messages.SubscribeMessage;
@@ -48,6 +49,8 @@ public class MQTTHandler extends IoHandlerAdapter implements INotifier {
case PUBLISH:
handlePublish(session, (PublishMessage) msg);
break;
case PINGREQ:
session.write(new PingRespMessage());
case DISCONNECT:
handleDisconnect(session, (DisconnectMessage) msg);