diff options
Diffstat (limited to '')
-rw-r--r-- | lib/presque/worker.pm | 11 |
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(); } |