diff --git a/consume.go b/consume.go
index f1c9829..805ae66 100644
--- a/consume.go
+++ b/consume.go
@@ -259,9 +259,7 @@ func handlerGoroutine(consumer *Consumer, msgs <-chan amqp.Delivery, consumeOpti
 }
 
 func (consumer *Consumer) waitForHandlerCompletion(ctx context.Context) error {
-	if ctx == nil {
-		ctx = context.Background()
-	} else if ctx.Err() != nil {
+	if ctx.Err() != nil {
 		return ctx.Err()
 	}
 	c := make(chan struct{})