Merge pull request #13 from stefankleff/patch-1

Update SqsWorker.php
Webador · Oct 2, 2014 · e5db7b0 · e5db7b0
2 parents 93c0058 + 38170fb
commit e5db7b0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/SlmQueueSqs/Worker/SqsWorker.php b/src/SlmQueueSqs/Worker/SqsWorker.php
@@ -28,8 +28,10 @@ public function processJob(JobInterface $job, QueueInterface $queue)
         try {
             $job->execute();
             $queue->delete($job);
+            return static::JOB_SUCCESSFUL;
         } catch (Exception $exception) {
             // Do nothing, the job will be reinserted automatically for another try
+            return static::JOB_RESCHEDULED;
         }
     }
 }