From 52a5425749bb9e38af549a49138b3867f0cdd9ce Mon Sep 17 00:00:00 2001
From: niko <nikomomo@gmail.com>
Date: Wed, 28 Jul 2010 12:03:31 +0200
Subject: sub log(msg[,level]) helper added

---
 lib/presque/worker/Role/Logger.pm | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'lib/presque')

diff --git a/lib/presque/worker/Role/Logger.pm b/lib/presque/worker/Role/Logger.pm
index ff0090e..ccc7b0f 100644
--- a/lib/presque/worker/Role/Logger.pm
+++ b/lib/presque/worker/Role/Logger.pm
@@ -84,4 +84,12 @@ before _kill_child => sub {
     );
 };
 
+sub log {
+	my( $self, $msg, $level ) = @_;
+	$self->logger->log(
+		message => $msg, 
+		level   => $level || 'info',
+	);
+}
+
 1;
-- 
cgit 1.4.1


From 6a2212cf45cb50eb79e4cabc5788e5155a9292d7 Mon Sep 17 00:00:00 2001
From: niko <nikomomo@gmail.com>
Date: Wed, 28 Jul 2010 12:46:15 +0200
Subject: log helper improved

---
 lib/presque/worker/Role/Logger.pm | 39 ++++++++++-----------------------------
 1 file changed, 10 insertions(+), 29 deletions(-)

(limited to 'lib/presque')

diff --git a/lib/presque/worker/Role/Logger.pm b/lib/presque/worker/Role/Logger.pm
index ccc7b0f..6c286c4 100644
--- a/lib/presque/worker/Role/Logger.pm
+++ b/lib/presque/worker/Role/Logger.pm
@@ -42,54 +42,35 @@ sub _load_log_engine {
 
 before start => sub {
     my $self = shift;
-
-    $self->logger->log(
-        level   => 'info',
-        message => "presque worker ["
-          . $self->worker_id
-          . "] : start to listen for "
-          . $self->queue_name
-    );
+    $self->log( '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',
-    );
+    $self->log( 'start to work', 'debug' );
 };
 
 before _shutdown => sub {
     my $self = shift;
-    $self->logger->log(
-        level   => 'info',
-        message => 'worker ' . $self->worker_id . ' shuting down'
-    );
+    $self->log( 'shutting down' );
 };
 
 before _graceful_shutdown => sub {
     my $self = shift;
-    $self->logger->log(
-        level   => 'info',
-        message => 'worker ' . $self->worker_id . ' kill child'
-    );
+    $self->log( 'kill child' );
 };
 
 before _kill_child => sub {
     my $self = shift;
-    $self->logger->log(
-        level   => 'info',
-        message => 'worker ' . $self->worker_id . ' shuting down gracefuly'
-    );
+    $self->log( 'shutting down gracefuly' );
 };
 
 sub log {
-	my( $self, $msg, $level ) = @_;
-	$self->logger->log(
-		message => $msg, 
-		level   => $level || 'info',
-	);
+    my( $self, $msg, $level ) = @_;
+    $self->logger->log(
+        message => '['.$self->worker_id.'] '.$msg,
+        level   => $level || 'info',
+    );
 }
 
 1;
-- 
cgit 1.4.1