File Coverage

blib/lib/Plack/App/ServiceStatus/NetStomp.pm

Criterion	Covered	Total	%
statement	29	29	100.0
branch	2	2	100.0
condition			n/a
subroutine	9	9	100.0
pod	0	1	0.0
total	40	41	97.5

package Plack::App::ServiceStatus::NetStomp;

# ABSTRACT: Check Net::Stomp connection

our $VERSION = '0.911'; # VERSION

use 5.018;
use strict;
use warnings;
use Module::Runtime qw(require_module);
use Try::Tiny;

sub check {
    my ( $class, $stomp ) = @_;

    if ( ref $stomp eq 'CODE' ) {
        $stomp = $stomp->();
    }

    require_module 'Net::Stomp::Frame';
    my $reconnect_attempts = $stomp->reconnect_attempts();
    return try {
        $stomp->reconnect_attempts(1);
        my $transaction_id = $stomp->_get_next_transaction;
        my $begin_frame    = Net::Stomp::Frame->new(
            {
                command => 'BEGIN',
                headers => { transaction => $transaction_id }
            }
        );
        $stomp->send_frame($begin_frame);
        my $abort_frame = Net::Stomp::Frame->new(
            {
                command => 'ABORT',
                headers => { transaction => $transaction_id }
            }
        );
        $stomp->send_frame($abort_frame);
        return 'ok';
    }
    catch {
        return 'nok', 'Not connected: ' . $_;
    }
    finally {
        $stomp->reconnect_attempts($reconnect_attempts);
    }
}

1;

__END__