summaryrefslogtreecommitdiff
path: root/lib/presque/worker/Role/Logger.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/presque/worker/Role/Logger.pm')
-rw-r--r--lib/presque/worker/Role/Logger.pm44
1 files changed, 44 insertions, 0 deletions
diff --git a/lib/presque/worker/Role/Logger.pm b/lib/presque/worker/Role/Logger.pm
index 3b6b317..4285b55 100644
--- a/lib/presque/worker/Role/Logger.pm
+++ b/lib/presque/worker/Role/Logger.pm
@@ -21,4 +21,48 @@ has logger => (
}
);
+before start => sub {
+ my $self = shift;
+
+ $self->logger->log(
+ level => 'info',
+ message => "presque worker ["
+ . $self->worker_id
+ . "] : start to listen for "
+ . $self->queue_name
+ );
+};
+
+before work => sub {
+ my $self = shift;
+ $self->logger->log(
+ level => 'debug',
+ message => $self->worker_id . ' start to work',
+ );
+};
+
+before _shutdown => sub {
+ my $self = shift;
+ $self->logger->log(
+ level => 'info',
+ message => 'worker ' . $self->worker_id . ' shuting down'
+ );
+};
+
+before _graceful_shutdown => sub {
+ my $self = shift;
+ $self->logger->log(
+ level => 'info',
+ message => 'worker ' . $self->worker_id . ' kill child'
+ );
+};
+
+before _kill_child => sub {
+ my $self = shift;
+ $self->logger->log(
+ level => 'info',
+ message => 'worker ' . $self->worker_id . ' shuting down gracefuly'
+ );
+};
+
1;