diff options
author | franck cuny <franck@lumberjaph.net> | 2010-05-09 11:02:17 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-05-09 11:02:17 +0200 |
commit | 19da1e2e0275816cd8bad717b36c2570b378dbe9 (patch) | |
tree | 2dc2d587b22ece9f2464970dd73b8ad7aa547b29 /lib/presque/Role/QueueName.pm | |
parent | update regex for restqueue handler (diff) | |
download | presque-19da1e2e0275816cd8bad717b36c2570b378dbe9.tar.gz |
role to create various queue_name
Diffstat (limited to 'lib/presque/Role/QueueName.pm')
-rw-r--r-- | lib/presque/Role/QueueName.pm | 35 |
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; |