rename roles

1 files changed, 23 insertions, 0 deletions

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;