diff --git a/wshandler/room.go b/wshandler/room.go index c04a946..762e165 100644 --- a/wshandler/room.go +++ b/wshandler/room.go @@ -55,6 +55,7 @@ func (r *room) loop(ctx context.Context, conns *map[string]*wsconn) (normalEnd b } }() + tag := "#" + r.name for { select { case <-ctx.Done(): @@ -70,7 +71,7 @@ func (r *room) loop(ctx context.Context, conns *map[string]*wsconn) (normalEnd b ds := DownstreamMessage{ Alias: msg.Alias, Body: msg.Body, - Tag: append(msg.Tag, r.name), + Tag: append(msg.Tag, tag), } bt, _ := json.Marshal(ds)