yves/meowlib
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Add RedisRouter.Publish method to store and publish messages
Some checks failed
continuous-integration/drone/push Build is failing
Details

Browse Source
This commit is contained in:
ycc 2024-04-23 23:35:23 +02:00
parent 5491244d01
commit a3557d5183
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
server/router.go
View File

@ -110,6 +110,7 @@ func (r *RedisRouter) storeMessage(msg *meowlib.ToServerMessage) (*meowlib.FromS
return nil, err return nil, err
} }
r.Client.ZAdd(usrmsg.Destination, redis.Z{Score: float64(time.Now().Unix()), Member: out}) r.Client.ZAdd(usrmsg.Destination, redis.Z{Score: float64(time.Now().Unix()), Member: out})
r.Client.Publish(usrmsg.Destination, "!")
} }
from_server.UuidAck = msg.Uuid from_server.UuidAck = msg.Uuid
return &from_server, nil return &from_server, nil