view release on metacpan or  search on metacpan

t/emit-json.t  view on Meta::CPAN

});


eval {
    local $SIG{ALRM} = sub { die "timed out\n"; };
    alarm 5;
    ok my $ret = IPC::Transit::receive(qname => 'test_out');
    is $ret->{runner_message_type}, undef, 'first message correctly has no defined runner_message_type';
};
alarm 0;
ok !$@, 'no exception thrown';


ok IPC::Transit::send(qname => 'tqueue', message => {
    '.multimodule' => {
        control => [
            {   type => 'cleanly_exit',
                exit_externals => 1,
            }
        ],
    }

t/emit-multi-json.t  view on Meta::CPAN

eval {
    local $SIG{ALRM} = sub { die "timed out\n"; };
    alarm 5;
    ok my $ret = IPC::Transit::receive(qname => 'test_out');
    is $ret->{runner_message_type}, undef, 'first message correctly has no defined runner_message_type';
    is $ret->{json}, 'thing1', 'first message correctly had "json" set to "thing1"';
};
alarm 0;
ok !$@, 'no exception thrown for first message';

eval {
    local $SIG{ALRM} = sub { die "timed out\n"; };
    alarm 5;
    ok my $ret = IPC::Transit::receive(qname => 'test_out');
    is $ret->{runner_message_type}, undef, 'second message correctly has no defined runner_message_type';
    is $ret->{json}, 'thing2', 'second message correctly had "json" set to "thing2"';
};
alarm 0;
ok !$@, 'no exception thrown for second message';

ok IPC::Transit::send(qname => 'tqueue', message => {
    '.multimodule' => {
        control => [
            {   type => 'cleanly_exit',
                exit_externals => 1,
            }
        ],
    }
}), 'sent program exit request';