summaryrefslogtreecommitdiff
path: root/lib/presque/Role/QueueName.pm
blob: 7cc9debd4666b84a4eac9f86c6c3aceb303dd385 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
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;