Group
Extension

Matches 1

Resque-Plugin-Delay ( M/ME/MERU/Resque-Plugin-Delay-0.05.tar.gz, MERU, 2018; MetaCPAN )
Resque-Plugin-Delay/lib/Resque/Plugin/Delay/Dequeue.pm ( view source; MetaCPAN )
que::Plugin::Delay::Dequeue;
use 5.008001;
use strict;
use warnings;

use Moose::Role;
use JSON qw/decode_json/;

around pop => sub {
    my ( $orig, $self, $queue ) = @_;
    my $payload = $self->red
is->lpop($self->key( queue => $queue ));
    return unless $payload;
    $payload = decode_json($payload);

    my $job = $self->new_job({
        payload => $payload,
        queue   => $queue
    })

Powered by Groonga
Maintained by Kenichi Ishigaki <ishigaki@cpan.org>. If you find anything, submit it on GitHub.