Yet Another CPAN Grep

Message-Passing-Fluentd ( W/WR/WREIS/Message-Passing-Fluentd-0.02.tar.gz, WREIS, 2019; MetaCPAN )

Message-Passing-Fluentd/lib/Message/Passing/Output/Fluentd.pm ( view source; MetaCPAN )

age::Passing::Output::Fluentd;

use Moo;
use namespace::autoclean;
use Try::Tiny;
use JSON::MaybeXS qw( decode_json );
use Message::Passing::Exception::Decoding;

with qw(
  Message::Passing::Fluentd:

pp_log'  });

sub consume {
  my ($self, $msg) = @_;
  $msg = try {
    ref($msg) ? $msg : decode_json($msg)
  } catch {
    $self->error->consume(Message::Passing::Exception::Decoding->new(
      exc