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

Cleanedup MQTTHandler after the move of logic into the event loop

Browse Source
This commit is contained in:
selva.andre
2012-09-04 16:23:11 +02:00
parent 0e1a3cef6c
commit 8f3041fe56
1 changed files with 1 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files
parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java
+1 -35
View File
@@ -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);