From 2dbf10d905fc0a6d7af917741849377f975540ed Mon Sep 17 00:00:00 2001
From: "selva.andre" <andrea@sempai>
Date: Fri, 10 Aug 2012 19:36:14 +0200
Subject: [PATCH] Added to the server's  the handling of PING messages

---
 .../src/main/java/org/dna/mqtt/moquette/server/Server.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/parser/src/main/java/org/dna/mqtt/moquette/server/Server.java b/parser/src/main/java/org/dna/mqtt/moquette/server/Server.java
index 366bf421..c0cb8307 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/server/Server.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/server/Server.java
@@ -14,11 +14,14 @@ import org.dna.mqtt.moquette.proto.ConnAckEncoder;
 import org.dna.mqtt.moquette.proto.ConnectDecoder;
 import org.dna.mqtt.moquette.proto.DisconnectDecoder;
 import org.dna.mqtt.moquette.proto.MQTTLoggingFilter;
+import org.dna.mqtt.moquette.proto.PingReqDecoder;
+import org.dna.mqtt.moquette.proto.PingRespEncoder;
 import org.dna.mqtt.moquette.proto.PublishDecoder;
 import org.dna.mqtt.moquette.proto.PublishEncoder;
 import org.dna.mqtt.moquette.proto.SubAckEncoder;
 import org.dna.mqtt.moquette.proto.SubscribeDecoder;
 import org.dna.mqtt.moquette.proto.messages.ConnAckMessage;
+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.slf4j.Logger;
@@ -46,12 +49,14 @@ public class Server {
         decoder.addMessageDecoder(new PublishDecoder());
         decoder.addMessageDecoder(new SubscribeDecoder());
         decoder.addMessageDecoder(new DisconnectDecoder());
+        decoder.addMessageDecoder(new PingReqDecoder());
         
         DemuxingProtocolEncoder encoder = new DemuxingProtocolEncoder();
 //        encoder.addMessageEncoder(ConnectMessage.class, new ConnectEncoder());
         encoder.addMessageEncoder(ConnAckMessage.class, new ConnAckEncoder());
         encoder.addMessageEncoder(SubAckMessage.class, new SubAckEncoder());
         encoder.addMessageEncoder(PublishMessage.class, new PublishEncoder());
+        encoder.addMessageEncoder(PingRespMessage.class, new PingRespEncoder());
         
         m_acceptor = new NioSocketAcceptor();