mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
fix live msg
This commit is contained in:
parent
c24b8a1662
commit
796040076f
2 changed files with 2 additions and 1 deletions
|
|
@ -69,6 +69,7 @@ public class UserTokenContainer {
|
|||
if (StringUtils.isBlank(defaultToken)) {
|
||||
return StringUtils.EMPTY;
|
||||
} else {
|
||||
userTokens.putIfAbsent(principal, defaultToken);
|
||||
return defaultToken;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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
|
||||
|
|
|
|||
Loading…
Reference in a new issue