lib/presque/Role/QueueName.pm


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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

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_unique {
    my ($self, $queue_name) = @_;
    return $queue_name . ':uniq';
}

sub _queue_key {
    my ($self, $queue_name, $uuid) = @_;
    return $queue_name.':'.$uuid;
}

sub _queue_stat {
    my ($self, $queue_name) = @_;
    return 'queuestat:'.$queue_name;
}

sub _queue_worker {
    my ($self, $worker_name) = @_;
    return 'worker:'.$worker_name;
}

sub _queue_failed {
    my ($self, $queue_name) = @_;
    return 'failed:'.$queue_name;
}

sub _queue_processed {
    my ($self, $queue_name) = @_;
    return 'processed:' . $queue_name;
}

1;