fix: Disable multiple subscription to the same topic

MoonSHRD · Sep 13, 2019 · 185ef48 · 185ef48
1 parent fbb2b84
commit 185ef48
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/main.go b/pkg/main.go
@@ -295,6 +295,10 @@ func SubscribeToTopic(topic string) {
 		log.Println("Manual subscription to service topic is not allowed!")
 		return
 	}
+	if _, ok := subscribedTopics[topic]; ok {
+		log.Println("You are already subscribed to the topic!")
+		return
+	}
 	incomingMessages := make(chan pubsub.Message)
 	subscription, err := Pb.Subscribe(topic)
 	if err != nil {