fix live msg

This commit is contained in:
Khalid Huseynov 2017-03-21 03:20:19 +09:00
parent c24b8a1662
commit 796040076f
2 changed files with 2 additions and 1 deletions

View file

@ -69,6 +69,7 @@ public class UserTokenContainer {
if (StringUtils.isBlank(defaultToken)) {
return StringUtils.EMPTY;
} else {
userTokens.putIfAbsent(principal, defaultToken);
return defaultToken;
}
}

View file

@ -53,7 +53,7 @@ public class ZeppelinhubWebsocket implements WebSocketListener {
public void onWebSocketConnect(Session session) {
LOG.info("Opening a new session to Zeppelinhub {}", session.hashCode());
this.zeppelinHubSession = session;
//send(ZeppelinhubUtils.liveMessage(token));
send(ZeppelinhubUtils.liveMessage(token));
}
@Override