diff --git a/manager/manager.go b/manager/manager.go index 9d16594..e92f7b6 100644 --- a/manager/manager.go +++ b/manager/manager.go @@ -19,10 +19,12 @@ func New(r storage.Cache) Manager { } } -func (em *eventManager) RegisterSubscriber(topic string, eventChan chan event.Event) error { - log.Info("Registering subscriber for topic:", topic) +func (em *eventManager) RegisterSubscriber(topics []string, eventChan chan event.Event) error { + log.Info("Registering subscriber for topic:", topics) - em.connections.Set(topic, eventChan) + for _, topic := range topics { + em.connections.Set(topic, eventChan) + } return nil }