about summary refs log tree commit diff
path: root/lib/presque/Role/Queue
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-06-28 10:13:19 +0200
committerfranck cuny <franck@lumberjaph.net>2010-06-28 10:13:19 +0200
commit84b5147670347eb26a75c27342d410a580b03de4 (patch)
tree71302d475e90f899516782014912129a2a468628 /lib/presque/Role/Queue
parentadd POD; fix queue size when null (diff)
downloadpresque-84b5147670347eb26a75c27342d410a580b03de4.tar.gz
store value for next delayed job, return info with control status
Diffstat (limited to 'lib/presque/Role/Queue')
-rw-r--r--lib/presque/Role/Queue/Names.pm5
1 files changed, 5 insertions, 0 deletions
diff --git a/lib/presque/Role/Queue/Names.pm b/lib/presque/Role/Queue/Names.pm
index 6a2b6a7..c371a50 100644
--- a/lib/presque/Role/Queue/Names.pm
+++ b/lib/presque/Role/Queue/Names.pm
@@ -12,6 +12,11 @@ sub _queue_delayed {
     return $queue_name.':delayed';
 }
 
+sub _queue_delayed_next {
+    my ($self, $queue_name) = @_;
+    return $queue_name.':delayed:next';
+}
+
 sub _queue_policy {
     my ($self, $queue_name) = @_;
     return $queue_name.':queuepolicy';