diff --git a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
index 535a8f14..2049b0ce 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
@@ -35,22 +35,12 @@ public class MQTTHandler extends IoHandlerAdapter {
         try {
             switch (msg.getMessageType()) {
                 case CONNECT:
-                    handleConnect(session, (ConnectMessage) msg);
-                    break;
                 case SUBSCRIBE:
-                    handleSubscribe(session, (SubscribeMessage) msg);
-                    break;
                 case UNSUBSCRIBE:
-                    handleUnsubscribe(session, (UnsubscribeMessage) msg);
-                    break;    
                 case PUBLISH:
-                    handlePublish(session, (PublishMessage) msg);
-                    break;
                 case PINGREQ:
-                    session.write(new PingRespMessage());
-                    break;
                 case DISCONNECT:
-                    handleDisconnect(session, (DisconnectMessage) msg);
+                    m_messaging.handleProtocolMessage(session, msg);
                     break;
             }
         } catch (Exception ex) {
@@ -58,30 +48,6 @@ public class MQTTHandler extends IoHandlerAdapter {
         }
     }
 
-    protected void handleConnect(IoSession session, ConnectMessage msg) {
-        LOG.info("handleConnect invoked");
-
-        m_messaging.handleProtocolMessage(session, msg);
-    }
-
-    protected void handleSubscribe(IoSession session, SubscribeMessage msg) {
-        LOG.debug("handleSubscribe, registering the subscriptions");
-        m_messaging.handleProtocolMessage(session, msg);
-    }
-    
-    private void handleUnsubscribe(IoSession session, UnsubscribeMessage msg) {
-        LOG.info("unregistering the subscriptions");
-        m_messaging.handleProtocolMessage(session, msg);
-    }
-
-    protected void handlePublish(IoSession session, PublishMessage message) {
-        m_messaging.handleProtocolMessage(session, message);
-    }
-
-    protected void handleDisconnect(IoSession session, DisconnectMessage disconnectMessage) {
-        m_messaging.handleProtocolMessage(session, disconnectMessage);
-    }
-
     @Override
     public void sessionIdle(IoSession session, IdleStatus status) {
         session.close(false);