diff --git a/handler.go b/handler.go
index e50dd94..eacd93b 100644
--- a/handler.go
+++ b/handler.go
@@ -64,7 +64,7 @@ func NewClient(deps Deps) *Client {
 
 func StartConsumer(ctx context.Context, client *Client, chanLen int) chan []byte {
 	msgCh := make(chan []byte, chanLen)
-	go runConsumer(ctx, client)
+	go runConsumer(ctx, client, msgCh)
 
 	return msgCh
 }