diff --git a/consumer/queue.go b/consumer/queue.go
index 6fbd40e..1b396c5 100644
--- a/consumer/queue.go
+++ b/consumer/queue.go
@@ -42,5 +42,7 @@ func (c *Consumer[T]) Start(base context.Context) error {
 
 	defer conn.Close()
 
+	<-base.Done()
+
 	return nil
 }