diff --git a/server/router.go b/server/router.go index 8be5ce3..73c286e 100644 --- a/server/router.go +++ b/server/router.go @@ -110,6 +110,7 @@ func (r *RedisRouter) storeMessage(msg *meowlib.ToServerMessage) (*meowlib.FromS return nil, err } r.Client.ZAdd(usrmsg.Destination, redis.Z{Score: float64(time.Now().Unix()), Member: out}) + r.Client.Publish(usrmsg.Destination, "!") } from_server.UuidAck = msg.Uuid return &from_server, nil