diff --git a/src/Subscribers.php b/src/Subscribers.php
index 035b72f2d071de3814a9687ec52c64b362424f92..091c57eb9dd85286bec1d254e625ad95c9a94053 100644
--- a/src/Subscribers.php
+++ b/src/Subscribers.php
@@ -245,7 +245,7 @@ class Subscribers implements SubscribersInterface {
         ]);
 
         // Check we didn't timeout.
-        if ($use_queue && $subscribe_options['queue']['end time'] && time() < $subscribe_options['queue']['end time']) {
+        if ($use_queue && $subscribe_options['end time'] && time() < $subscribe_options['end time']) {
           continue 2;
         }
       }