summary refs log tree commit diff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--lib/presque/worker.pm11
1 files changed, 9 insertions, 2 deletions
diff --git a/lib/presque/worker.pm b/lib/presque/worker.pm
index e73f022..2b6acea 100644
--- a/lib/presque/worker.pm
+++ b/lib/presque/worker.pm
@@ -88,8 +88,15 @@ sub start {
     my $self = shift;
 
     while (!$self->shut_down) {
-        my $job = try {
-            $self->pull(queue_name => $self->queue_name, worker_id => $self->worker_id);
+        my $job;
+        try {
+            $job = $self->pull(
+                queue_name => $self->queue_name,
+                worker_id  => $self->worker_id,
+            );
+        }
+        catch {
+            $self->logger->error($_);
         };
         $job ? $self->work($job) : $self->idle();
     }