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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
package Mojo::RabbitMQ::Client::Method;
use Mojo::Base 'Mojo::EventEmitter';
has is_sent => 0;
has client => undef;
has channel => undef;
has name => undef;
has arguments => sub { {} };
has expect => undef;
sub setup {
my $self = shift;
$self->name(shift);
$self->arguments(shift);
$self->expect(shift);
return $self;
}
sub deliver {
my $self = shift;
return 0 unless $self->channel->_assert_open();
$self->client->_write_expect(
$self->name => $self->arguments,
$self->expect => sub { $self->emit('success', @_); },
sub { $self->emit('error', @_); }, $self->channel->id,
);
$self->is_sent(1);
return 1;
}
1;
=encoding utf8
=head1 NAME
Mojo::RabbitMQ::Client::Method - it's a generic class for all AMQP method calls
=head1 SYNOPSIS
use Mojo::RabbitMQ::Client::Method;
my $method = Mojo::RabbitMQ::Client::Method->new(
client => $client,
channel => $channel
)->setup(
'Basic::Consume' => {
...
},
['Basic::ConsumeOk', ...]
);
# Watch for errors
$method->on(error => sub { warn "Error in reception: " . $_[1] });
# Send this frame to AMQP
$method->deliver;
=head1 DESCRIPTION
L<Mojo::RabbitMQ::Client::Method> is general class for every AMQP method call.
=head1 EVENTS
L<Mojo::RabbitMQ::Client::Method> inherits all events from L<Mojo::EventEmitter> and can emit the
following new ones.
=head2 success
$method->on(success => sub {
my ($method, $frame) = @_;
...
});
Emitted when one of expected replies is received.
=head2 message
Can be emitted by consumption & get methods.
=head2 empty
Can be emitted by get method, when no messages are available on queue.
=head1 ATTRIBUTES
L<Mojo::RabbitMQ::Client::Method> has following attributes.
=head2 is_sent
$method->is_sent ? "Method was sent" : "Method is still pending delivery";
=head2 client
my $client = $method->client;
$method->client($client);
=head2 name
my $name = $method->name;
$method->name('Basic::Get');
=head2 arguments
my $arguments = $method->arguments;
$method->arguments({no_ack => 1, ticket => 0, queue => 'amq.queue'});
=head2 expect
my $expectations = $method->expect;
$method->expect([qw(Basic::GetOk Basic::GetEmpty)]);
=head1 METHODS
L<Mojo::RabbitMQ::Client::Method> inherits all methods from L<Mojo::EventEmitter> and implements
the following new ones.
=head2 setup
$method = $method->setup($name, $arguments, $expectations);
Sets AMQP method name, its arguments and expected replies.
=head2 deliver
my $status = $method->deliver();
This delivers AMQP method call to server. Returns C<<false>> when channel is not open, C<<true>> otherwise.
On successful delivery->reply cycle emits C<<success>> event.
C<<error>> is emitted when none of expected replies are received.
=head1 SEE ALSO
L<Mojo::RabbitMQ::Client::Channel>, L<Mojo::RabbitMQ::Client>
=head1 COPYRIGHT AND LICENSE
Copyright (C) 2015-2017, Sebastian Podjasek and others
Based on L<AnyEvent::RabbitMQ> - Copyright (C) 2010 Masahito Ikuta, maintained by C<< bobtfish@bobtfish.net >>
This program is free software, you can redistribute it and/or modify it under the terms of the Artistic License version 2.0.
=cut
|
