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
})