diff --git a/sam/websocket/session_incoming_channel.go b/sam/websocket/session_incoming_channel.go index 51c876e8c..4697d1bb6 100644 --- a/sam/websocket/session_incoming_channel.go +++ b/sam/websocket/session_incoming_channel.go @@ -64,6 +64,11 @@ func (s *Session) channelCreate(ctx context.Context, p *incoming.ChannelCreate) return err } + // Explicitly subscribe to newly created channel + s.subs.Add(uint64toa(ch.ID)) + + // @todo this should go over all user's sessons and subscribe there as well + pl := payloadFromChannel(ch) if ch.Type == types.ChannelTypePublic {