update: register subscriber to multiple topics

sreeram77 · Apr 15, 2023 · 5cb4119 · 5cb4119
1 parent 0a01dd3
commit 5cb4119
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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
 }