NAME
Job::Async::Worker::Redis - Net::Async::Redis worker implementation for Job::Async::Worker
SYNOPSIS
DESCRIPTION
incoming_job
Source for jobs received from the BRPOP(LPUSH)
queue wait.
on_job_received
Called for each job that's received.
pending_queues
Note that reliable mode only supports a single queue, and will fail if you attempt to start with multiple queues defined.
processing_queue
start
stop
Requests to stop processing.
Returns a future which will complete when all currently-processing jobs have finished.
max_concurrent_jobs
Number of jobs to process in parallel. Defaults to 1.
job_poll_interval
Polling interval (e.g. for BRPOPLPUSH
in reliable
mode), in seconds.
Defaults to 3 seconds.
INHERITED METHODS
- Job::Async::Worker
- IO::Async::Notifier
-
add_child, adopt_future, adopted_futures, can_event, children, configure_unknown, debug_printf, get_loop, invoke_error, invoke_event, loop, make_event_cb, maybe_invoke_event, maybe_make_event_cb, new, notifier_name, parent, remove_child, remove_from_parent
AUTHOR
Tom Molesworth <TEAM@cpan.org>
LICENSE
Copyright Tom Molesworth 2016-2019. Licensed under the same terms as Perl itself.