thingsboard-aplcache

Merge pull request #243 from xjz/master Fix to the process

8/11/2017 10:09:10 AM

Details

diff --git a/application/src/main/java/org/thingsboard/server/actors/session/SessionManagerActor.java b/application/src/main/java/org/thingsboard/server/actors/session/SessionManagerActor.java
index 9f8084b..f9b54a8 100644
--- a/application/src/main/java/org/thingsboard/server/actors/session/SessionManagerActor.java
+++ b/application/src/main/java/org/thingsboard/server/actors/session/SessionManagerActor.java
@@ -50,7 +50,9 @@ public class SessionManagerActor extends ContextAwareActor {
 
     @Override
     public void onReceive(Object msg) throws Exception {
-        if (msg instanceof SessionAwareMsg) {
+        if (msg instanceof SessionCtrlMsg) {
+            onSessionCtrlMsg((SessionCtrlMsg) msg);
+        } else if (msg instanceof SessionAwareMsg) {
             forwardToSessionActor((SessionAwareMsg) msg);
         } else if (msg instanceof SessionTerminationMsg) {
             onSessionTermination((SessionTerminationMsg) msg);
@@ -58,8 +60,6 @@ public class SessionManagerActor extends ContextAwareActor {
             onTermination((Terminated) msg);
         } else if (msg instanceof SessionTimeoutMsg) {
             onSessionTimeout((SessionTimeoutMsg) msg);
-        } else if (msg instanceof SessionCtrlMsg) {
-            onSessionCtrlMsg((SessionCtrlMsg) msg);
         } else if (msg instanceof ClusterEventMsg) {
             broadcast(msg);
         }