File Coverage

blib/lib/Plack/Middleware/AccessLog/Structured/ZeroMQ.pm

Criterion	Covered	Total	%
statement	13	15	86.6
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	18	20	90.0

package Plack::Middleware::AccessLog::Structured::ZeroMQ;
{
  $Plack::Middleware::AccessLog::Structured::ZeroMQ::VERSION = '0.001000';
}
use parent qw(Plack::Middleware::AccessLog::Structured);

# ABSTRACT: Access log middleware which passes structured log messages into ZeroMQ

use strict;
use warnings;

use MRO::Compat;
use Message::Passing::Output::ZeroMQ;



sub new {
	my ($class, $arg_ref) = @_;

	my $self = $class->next::method($arg_ref);

	unless ($self->logger()) {
		my $output = Message::Passing::Output::ZeroMQ->new(
			connect => $self->{connect} || 'tcp://127.0.0.1:5552',
		);
		$self->logger(sub {
			$output->consume(@_);
		});
	}

	return $self;
}



1;

__END__