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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
package Message::Passing::AMQP::Role::DeclaresQueue;
use Moo::Role;
use Types::Standard qw( Bool Str HashRef );
use Scalar::Util qw/ weaken /;
use namespace::autoclean;
with 'Message::Passing::AMQP::Role::HasAChannel';
has queue_name => (
is => 'ro',
isa => Str,
predicate => '_has_queue_name',
lazy => 1,
default => sub {
my $self = shift;
$self->_queue->method_frame->queue;
}
);
# FIXME - Should auto-build from _queue as above
has queue_durable => (
is => 'ro',
isa => Bool,
default => 1,
);
has queue_exclusive => (
is => 'ro',
isa => Bool,
default => 0,
);
has queue_auto_delete => (
is => 'ro',
isa => Bool,
default => 0,
);
has _queue => (
is => 'ro',
writer => '_set_queue',
predicate => '_has_queue',
);
has queue_arguments => (
isa => HashRef,
is => 'ro',
default => sub { {} }, # E.g. 'x-ha-policy' => 'all'
);
after '_set_channel' => sub {
my $self = shift;
weaken($self);
$self->_channel->declare_queue(
arguments => $self->queue_arguments,
durable => $self->queue_durable,
exclusive => $self->queue_exclusive,
auto_delete => $self->queue_auto_delete,
$self->_has_queue_name ? (queue => $self->queue_name) : (),
on_success => sub {
$self->_set_queue(shift());
},
on_failure => sub {
warn("Failed to get queue");
$self->_clear_channel;
},
);
};
1;
=head1 NAME
Message::Passing::AMQP::Role::DeclaresQueue - Role for instances which have an AMQP queue.
=head1 ATTRIBUTES
=head2 queue_name
Defines the queue name, defaults to the name returned by the server.
The server may place restrictions on queue names it generates that
make them unsuitable in scenarios involving server restarts.
Recommend explicitly defining the queue name in those cases.
=head2 queue_durable
Defines if the queue is durable, defaults to true.
=head2 queue_exclusive
Defines if the queue is exclusive, defaults to false.
=head2 queue_arguments
Defines queue arguments, defaults to an empty hashref.
=head2 queue_auto_delete
If true, the queue is flagged as auto-delete, defaults to false.
=head1 AUTHOR, COPYRIGHT AND LICENSE
See L<Message::Passing::AMQP>.
=cut
|
