diff --git a/pkg/morph/event/listener.go b/pkg/morph/event/listener.go index 4fb92da50..dd3c7d216 100644 --- a/pkg/morph/event/listener.go +++ b/pkg/morph/event/listener.go @@ -621,6 +621,7 @@ func (l *listener) RegisterNotaryHandler(hi NotaryHandlerInfo) { func (l *listener) Stop() { l.stopOnce.Do(func() { l.subscriber.Close() + l.pool.Release() }) l.wg.Wait() }