about summary refs log tree commit diff
path: root/lib/presque/Role/QueueName.pm
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-05-09 11:02:17 +0200
committerfranck cuny <franck@lumberjaph.net>2010-05-09 11:02:17 +0200
commit19da1e2e0275816cd8bad717b36c2570b378dbe9 (patch)
tree2dc2d587b22ece9f2464970dd73b8ad7aa547b29 /lib/presque/Role/QueueName.pm
parentupdate regex for restqueue handler (diff)
downloadpresque-19da1e2e0275816cd8bad717b36c2570b378dbe9.tar.gz
role to create various queue_name
Diffstat (limited to 'lib/presque/Role/QueueName.pm')
-rw-r--r--lib/presque/Role/QueueName.pm35
1 files changed, 35 insertions, 0 deletions
diff --git a/lib/presque/Role/QueueName.pm b/lib/presque/Role/QueueName.pm
new file mode 100644
index 0000000..7cc9deb
--- /dev/null
+++ b/lib/presque/Role/QueueName.pm
@@ -0,0 +1,35 @@
+package presque::Role::QueueName;
+
+use Moose::Role;
+
+sub _queue {
+    my ($self, $queue_name) = @_;
+    return $queue_name.':queue';
+}
+
+sub _queue_delayed {
+    my ($self, $queue_name) = @_;
+    return $queue_name.':delayed';
+}
+
+sub _queue_policy {
+    my ($self, $queue_name) = @_;
+    return $queue_name.':queuepolicy';
+}
+
+sub _queue_uuid {
+    my ($self, $queue_name) = @_;
+    return $queue_name;':UUID';
+}
+
+sub _queue_key {
+    my ($self, $queue_name, $uuid) = @_;
+    return $queue_name.':'.$uuid;
+}
+
+sub _queue_stat {
+    my ($self, $queue_name) = @_;
+    return 'queuestat:'.$queue_name;
+}
+
+1;