File Coverage

blib/lib/XAS/Logmon/Output/Spool.pm

Criterion	Covered	Total	%
statement	9	25	36.0
branch	0	4	0.0
condition	0	3	0.0
subroutine	3	9	33.3
pod	2	2	100.0
total	14	43	32.5

package XAS::Logmon::Output::Spool;

our $VERSION = '0.01';

use XAS::Factory;
use Try::Tiny::Retry ':all';

use XAS::Class
  debug      => 0,
  version    => $VERSION,
  base       => 'XAS::Base',
  mixin      => 'XAS::Lib::Mixins::Handlers',
  utils      => ':validation',
  constants  => 'TRUE FALSE',
  accessors  => 'spool',
  filesystem => 'Dir',
;

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

sub put {
    my $self = shift;
    my ($data) = validate_params(\@_, [1]);

    retry {

        $self->spool->write($data);

    } delay_exp {

        30, 1000    # attempts, delay in milliseconds

    } retry_if {

        my $ex = $_;
        my $ref = ref($ex);

        if ($ref && $ex->isa('XAS::Exception')) {

            return TRUE if ($ex->match_type('xas.lib.modules.spool'));

        }

        return FALSE;

    } catch {

        my $ex = $_;

        $self->exception_handler($ex);

    };

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub init {
    my $class = shift;

    my $self = $class->SUPER::init(@_);

    $self->{'spool'} = XAS::Factory->module('spool', {
        -directory => Dir($self->env->spool, 'logs'),
        -lock      => Dir($self->env->spool, 'logs', 'locked')->path
    });

    return $self;

}

1;

__END__