From f2d8737789d522570ea58896826c91571a254bb0 Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Sun, 9 May 2010 11:12:07 +0200
Subject: use presque::r::qn

---
 lib/presque/ControlHandler.pm | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

(limited to 'lib/presque/ControlHandler.pm')

diff --git a/lib/presque/ControlHandler.pm b/lib/presque/ControlHandler.pm
index f900ea9..02136d1 100644
--- a/lib/presque/ControlHandler.pm
+++ b/lib/presque/ControlHandler.pm
@@ -2,6 +2,8 @@ package presque::ControlHandler;
 
 use Moose;
 extends 'Tatsumaki::Handler';
+with qw/presque::Role::QueueName/;
+
 __PACKAGE__->asynchronous(1);
 
 before [qw/get post/] => sub {
@@ -18,14 +20,16 @@ sub get {
         return;
     }
 
-    my $key = 'queuestat:' . $queue_name;
+    my $key = $self->_queue_stat($queue_name);
     $self->application->redis->get(
         $key,
         sub {
             my $status = shift;
             $self->finish(
-                JSON::encode_json(
-                    { queue => $queue_name, status => $status }
+                JSON::encode_json( {
+                        queue  => $queue_name,
+                        status => $status
+                    }
                 )
             );
         }
@@ -60,14 +64,18 @@ sub post {
 
 sub _set_status {
     my ( $self, $queue_name, $status ) = @_;
-    my $key = 'queuestat:' . $queue_name;
+    my $key = $self->_queue_stat($queue_name);
 
     $self->application->redis->set(
         $key, 0,
         sub {
             my $res = shift;
             $self->finish(
-                JSON::encode_json( { queue => $queue_name, status => $res } )
+                JSON::encode_json( {
+                        queue  => $queue_name,
+                        status => $res
+                    }
+                )
             );
         }
     );
-- 
cgit 1.4.1