t::MD5 qw(md5_hex);
use Time::HiRes qw(usleep);
use Mojo::Redis2;
use RedisDB;
use JSON::XS qw(encode_json decode_json);
=head1 NAME
Mojo::Redis::Processor - Encapsulates the process for a Mojo app
->{prefix} . md5_hex($self->_payload);
}
sub _payload {
my $self = shift;
return JSON::XS::encode_json([$self->{data}, $self->{trigger}]);
}
sub _processed_channel {
my $self = shift;
next));
usleep($self->{usleep});
}
return if not $payload;
my $tmp = JSON::XS::decode_json($payload);
$self->{data} = $tmp->[0];
$self->{trigger} = $tmp->[1];
ret