File Coverage

blib/lib/Log/Log4perl/Appender/SpreadSession.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package Log::Log4perl::Appender::SpreadSession;
##################################################

use 5.008008;
use strict;
use warnings;

our $VERSION = '0.03';

our @ISA = qw/ Log::Log4perl::Appender /;

use Spread::Session;

##################################################
sub new {
##################################################
    my($class, %args) = @_;

    my $self = {
        group => $args{group},
    };

    # Create a new session
    eval {
        $self->{spread_session} = Spread::Session->new(
            spread_name  => $args{spread_name} ,
            private_name => $args{private_name},
        );
    };
    if ($@) {
        warn "ERROR creating new $class: $@\n";
    }

    bless $self, $class;

    return $self;
}

##################################################
sub log {
##################################################
    my ($self, %args) = @_;

    my $spread = $self->{spread_session};

    # do nothing if the Spread::Session object is missing
    return unless $spread;

    # publish the message to the specified group
    eval {
        $spread->publish( $self->{group}, $args{message} );
    };
    # If you got an error warn about it and clear the
    # Spread::Session object so we don't keep trying
    if ($@) {
        warn "ERROR logging to spread via ".ref($self).": $@\n";
        $self->{spread_session} = undef;
    }

    return;
}

1;

__END__