line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
1
|
|
|
|
|
|
|
package SQS::Worker::DecodeStorable { |
2
|
2
|
|
|
2
|
|
950
|
use Moose::Role; |
|
2
|
|
|
|
|
5
|
|
|
2
|
|
|
|
|
13
|
|
3
|
2
|
|
|
2
|
|
9767
|
use MIME::Base64; |
|
2
|
|
|
|
|
6
|
|
|
2
|
|
|
|
|
131
|
|
4
|
2
|
|
|
2
|
|
19
|
use Storable qw/thaw/; |
|
2
|
|
|
|
|
5
|
|
|
2
|
|
|
|
|
295
|
|
5
|
|
|
|
|
|
|
|
6
|
|
|
|
|
|
|
|
7
|
|
|
|
|
|
|
around process_message => sub { |
8
|
|
|
|
|
|
|
my ($orig, $self, $message) = @_; |
9
|
|
|
|
|
|
|
|
10
|
|
|
|
|
|
|
my $body; |
11
|
|
|
|
|
|
|
eval { |
12
|
|
|
|
|
|
|
$body = thaw( decode_base64($message->Body) ); |
13
|
|
|
|
|
|
|
}; |
14
|
|
|
|
|
|
|
if ($@) { |
15
|
|
|
|
|
|
|
$self->log->error("Error retrieving store file in message " . $message->ReceiptHandle . ": " . $@ . " for content " . $message->Body); |
16
|
|
|
|
|
|
|
die $@; |
17
|
|
|
|
|
|
|
} else { |
18
|
|
|
|
|
|
|
return $self->$orig(@$body); |
19
|
|
|
|
|
|
|
} |
20
|
|
|
|
|
|
|
}; |
21
|
|
|
|
|
|
|
|
22
|
|
|
|
|
|
|
} |
23
|
|
|
|
|
|
|
1; |