#!/usr/bin/perl

use 5.010;
use warnings;
use strict;

use Moo;
use MooX::Options;
use Message::Passing::DSL;

with 'Message::Passing::Role::Script';

sub build_chain {
  my ($self) = @_;
  message_chain {
    output elasticsearch => (
      class => "ElasticSearch",
      elasticsearch_servers => [qw(log1.nyi.mail.srv.osa:9200)],
    );
    decoder decode_json => (
      class => "JSON",
      output_to => "elasticsearch",
    );
    input zeromq => (
      class => "ZeroMQ",
      output_to => "decode_json",
      socket_bind => "tcp://*:9400",
      linger => 1,
    );
  };
}

__PACKAGE__->start;