summaryrefslogtreecommitdiff
path: root/lib/presque/worker.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/presque/worker.pm')
-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();
}