diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-29 10:25:31 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-29 10:25:31 +0200 |
| commit | c9be726e58479f903f391ddbbae1a271a9e1528e (patch) | |
| tree | 3a48d6c4ac8b7162fe8f7d1314c66e10eff98894 /lib | |
| parent | use try::tiny; send hash to mx::net::api (diff) | |
| download | presque-worker-c9be726e58479f903f391ddbbae1a271a9e1528e.tar.gz | |
log error
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(); } |