File Coverage

blib/lib/SQS/Consumers/DeleteAlways.pm

Criterion	Covered	Total	%
statement	21	21	100.0
branch	2	2	100.0
condition			n/a
subroutine	3	3	100.0
pod	0	1	0.0
total	26	27	96.3

package SQS::Consumers::DeleteAlways;
use Moose;
use namespace::autoclean;

sub fetch_message {
    my $self = shift;
    my $worker = shift;

    $worker->log->debug('Receiving Messages');
    my $message_pack = $worker->receive_message();

    $worker->log->debug(sprintf "Got %d messages", scalar(@{ $message_pack->Messages }));

    foreach my $message (@{$message_pack->Messages}) {
        $worker->log->info("Processing message " . $message->ReceiptHandle);
        # We have to delete the message from the queue in any case, but we don't
        # want to wait for the process to finish (if the process is longer than
        # the messages visibility timeout, then the message will possibly be redelivered
        $worker->delete_message($message);

        eval {
            $worker->process_message($message);
        };
        if ($@) {
            $worker->log->error("Exception caught: " . $@);
            $worker->on_failure->($worker, $message);
        }
    }
}

__PACKAGE__->meta->make_immutable;
1;