dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix to the process of SessionAwareMsg and SessionCtrlMsg of SessionManagerAactor's OnReceive

Browse Source
This commit is contained in:
xiaojizhong 2017-08-11 09:47:46 +08:00
parent d426d0c0ad
commit f5f186e47a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
application/src/main/java/org/thingsboard/server/actors/session/SessionManagerActor.java
View File

@ -50,7 +50,9 @@ public class SessionManagerActor extends ContextAwareActor {
@Override @Override
public void onReceive(Object msg) throws Exception { 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); forwardToSessionActor((SessionAwareMsg) msg);
} else if (msg instanceof SessionTerminationMsg) { } else if (msg instanceof SessionTerminationMsg) {
onSessionTermination((SessionTerminationMsg) msg); onSessionTermination((SessionTerminationMsg) msg);
@ -58,8 +60,6 @@ public class SessionManagerActor extends ContextAwareActor {
onTermination((Terminated) msg); onTermination((Terminated) msg);
} else if (msg instanceof SessionTimeoutMsg) { } else if (msg instanceof SessionTimeoutMsg) {
onSessionTimeout((SessionTimeoutMsg) msg); onSessionTimeout((SessionTimeoutMsg) msg);
} else if (msg instanceof SessionCtrlMsg) {
onSessionCtrlMsg((SessionCtrlMsg) msg);
} else if (msg instanceof ClusterEventMsg) { } else if (msg instanceof ClusterEventMsg) {
broadcast(msg); broadcast(msg);
} }