overflow_backup_2018_0455/overflow_gateway_webapp
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-03-23 01:10:12 +09:00
parent f854dbf21d
commit 0c7a5e3330
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
servlet/webapp/gateway_rpc_handlers.go
View File

@ -87,6 +87,8 @@ func (sh *GatewayRPCHandlers) Handshake(socketCTX cwf.SocketContext, ctx *fastht
socketCTX.SetAttribute(oogw.ClientTypeKey, oogw.MEMBER)
socketCTX.SetAttribute(oogw.TargetIDKey, userEmail)
logging.Logger().Debugf("Webapp: Client sessionID %s", sessionID)
return sessionID, nil
}

8
servlet/webapp/subscriber_handlers.go
View File

@ -32,14 +32,18 @@ func (sh *SubscriberHandlers) OnSubscribe(channel string, message oos.SubscribeM
}
for _, soc := range sockets {
soc.WriteMessage(websocket.TextMessage, message.Message)
if err := soc.WriteMessageUseWriter(websocket.TextMessage, message.Message); nil != err {
logging.Logger().Errorf("OnSubscribe: write error %v", err)
}
}
}
case oos.MEMBER_SESSION:
for _, sid := range message.Targets {
if soc := sh.GetSocket(sid); nil != soc {
soc.WriteMessage(websocket.TextMessage, message.Message)
if err := soc.WriteMessageUseWriter(websocket.TextMessage, message.Message); nil != err {
logging.Logger().Errorf("OnSubscribe: write error %v", err)
}
}
}
default: