diff --git a/pkg/service/roommanager.go b/pkg/service/roommanager.go index 2b35be7d1..f6a180036 100644 --- a/pkg/service/roommanager.go +++ b/pkg/service/roommanager.go @@ -47,6 +47,11 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route return nil, err } + ns, err := selector.CreateNodeSelector(conf) + if err != nil { + return nil, err + } + r := &LocalRoomManager{ RoomStore: rs, lock: sync.RWMutex{}, @@ -57,6 +62,7 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route currentNode: currentNode, webhookPool: workerpool.New(1), rooms: make(map[string]*rtc.Room), + selector: ns, } // hook up to router