From b7c2585742ec2e5a61e1987f45279c4215ee12d0 Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Tue, 11 Sep 2012 23:19:44 +0200
Subject: [PATCH] Fixed encoders and decoders declaration for the broker

---
 .../src/main/java/org/dna/mqtt/moquette/server/Server.java | 7 +++++++
 1 file changed, 7 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 81184f64..69647518 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
@@ -46,6 +46,10 @@ public class Server {
         DemuxingProtocolDecoder decoder = new DemuxingProtocolDecoder();
         decoder.addMessageDecoder(new ConnectDecoder());
         decoder.addMessageDecoder(new PublishDecoder());
+        decoder.addMessageDecoder(new PubAckDecoder());
+        decoder.addMessageDecoder(new PubRelDecoder());
+        decoder.addMessageDecoder(new PubRecDecoder());
+        decoder.addMessageDecoder(new PubCompDecoder());
         decoder.addMessageDecoder(new SubscribeDecoder());
         decoder.addMessageDecoder(new UnsubscribeDecoder());
         decoder.addMessageDecoder(new DisconnectDecoder());
@@ -57,6 +61,9 @@ public class Server {
         encoder.addMessageEncoder(SubAckMessage.class, new SubAckEncoder());
         encoder.addMessageEncoder(UnsubAckMessage.class, new UnsubAckEncoder());
         encoder.addMessageEncoder(PubAckMessage.class, new PubAckEncoder());
+        encoder.addMessageEncoder(PubRecMessage.class, new PubRecEncoder());
+        encoder.addMessageEncoder(PubCompMessage.class, new PubCompEncoder());
+        encoder.addMessageEncoder(PubRelMessage.class, new PubRelEncoder());
         encoder.addMessageEncoder(PublishMessage.class, new PublishEncoder());
         encoder.addMessageEncoder(PingRespMessage.class, new PingRespEncoder());