diff --git a/server/server.go b/server/server.go
index 3933a94..1ad0346 100644
--- a/server/server.go
+++ b/server/server.go
@@ -574,6 +574,7 @@ func New(ctx context.Context, opts ...Opt) (*Handler, error) {
 	h := &Handler{
 		consumersEventsMap: NewConsumersEventsMap(),
 		actions:            NewActions(conf.workerBufferSize),
+		closeSignal:        make(chan struct{}),
 	}
 
 	go h.processActions()