view release on metacpan or  search on metacpan

t/basic_runAt.t  view on Meta::CPAN

    my $err = $@;
    ok(!$err, "no exception for $test_name");
    if($err) {
        print STDERR "\$get_msg failed: $@\n";
        return undef;
    }
    delete $message->{$_} for @$deletes;
    is_deeply($message, $expected, $test_name);
}

#verify nothing came in
{   my $message = eval {
        local $SIG{ALRM} = sub { die "timed out\n"; };
        alarm 2;
        return IPC::Transit::receive(qname => 'test_out');
    };
    alarm 0;
    is($@, "timed out\n", 'verified no message was sent pre-configuration');
}
# configure basic runAt
ok IPC::Transit::send(qname => 'Scheduler', message => {

t/basic_runAt.t  view on Meta::CPAN

        }
    },
}), 'sent runAt config';
message_is(
    'basic_runAt',
    {   runAt => $runAt,
        source => 'Scheduler',
        scheduler_scheduled_key => 'basic_runAt',
    }, ['scheduler_create_ts','.ipc_transit_meta','scheduler_send_ts']
);
#verify nothing came in again
{   my $message = eval {
        local $SIG{ALRM} = sub { die "timed out\n"; };
        alarm 6;
        return IPC::Transit::receive(qname => 'test_out');
    };
    alarm 0;
    is($@, "timed out\n", 'verified no message was sent post-configuration and post single expected message');
}

sleep 6;