From 3e0680943aabcf85c24d79de268f824811ae9b1c Mon Sep 17 00:00:00 2001 From: Sarah Jamie Lewis Date: Fri, 9 Feb 2024 13:15:51 -0800 Subject: [PATCH] Prevent Duplicate Queue Subscription --- event/eventmanager.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/event/eventmanager.go b/event/eventmanager.go index 04f506d..8394667 100644 --- a/event/eventmanager.go +++ b/event/eventmanager.go @@ -95,6 +95,11 @@ func (em *manager) initialize() { func (em *manager) Subscribe(eventType Type, queue Queue) { em.mapMutex.Lock() defer em.mapMutex.Unlock() + for _, sub := range em.subscribers[eventType] { + if sub == queue { + return // don't add the same queue for the same event twice... + } + } em.subscribers[eventType] = append(em.subscribers[eventType], queue) }