lib/proletariat/subscriber.rb in proletariat-0.0.5 vs lib/proletariat/subscriber.rb in proletariat-0.0.6

@@ -308,9 +308,11 @@
           properties[:headers]['worker']   = properties[:worker]
 
           @scheduled_task = Concurrent::ScheduledTask.new(retry_delay) do
             requeue_message
           end
+
+          @scheduled_task.execute
         end
 
         # Public: Attempt to requeue the message immediately if pending or
         #         wait for natural completion.
         #