From 8404183f74704bef03136aa36947fb65c74fa49c Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Thu, 24 Jun 2010 11:13:44 +0200
Subject: rename roles

---
 lib/presque/Role/Queue.pm | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)
 create mode 100644 lib/presque/Role/Queue.pm

(limited to 'lib/presque/Role/Queue.pm')

diff --git a/lib/presque/Role/Queue.pm b/lib/presque/Role/Queue.pm
new file mode 100644
index 0000000..c7b50f4
--- /dev/null
+++ b/lib/presque/Role/Queue.pm
@@ -0,0 +1,23 @@
+package presque::Role::Queue;
+
+use Moose::Role;
+
+sub new_queue {
+    my ($self, $queue_name, $lkey) = @_;
+    $self->application->redis->sadd('QUEUESET', $lkey);
+    my $ckey = $self->_queue_stat($queue_name);
+    $self->application->redis->set($ckey, 1);
+}
+
+sub push_job {
+    my ($self, $queue_name, $lkey, $key, $delayed) = @_;
+    my ($method, @args) = ('rpush', $lkey, $key);
+
+    if ($delayed) {
+        $method = 'zadd';
+        @args = ($queue_name . ':delayed', $delayed, $key);
+    }
+    $self->application->redis->$method(@args,);
+}
+
+1;
-- 
cgit 1.4.1