activecollab/jobsqueuecommands

Active Collab job queue commands

Maintainers

Details

github.com/activecollab/jobsqueuecommands

Source

Issues

Installs: 38

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 8

Forks: 0

Open Issues: 0

dev-master 2016-01-04 16:11 UTC

Requires

Requires (Dev)

MIT 0ff00bb39820766f2d9d4d2784ba41203c31e4e5

This package is auto-updated.

Last update: 2024-12-05 01:22:40 UTC

README

This package contains a couple of useful CLI commands that make work with activecollab/jobsqueue easier. Implemented commands are:

  • clear_failed_jobs - Clear failed jobs losts
  • create_tables - Create job queue tables (in case you are using MySQL queue)
  • enqueue -> Add job to the queue
  • failed_job_reasons - Find job by type, and return all distinct reasons why it failed in the past
  • failed_jobs - List content of failed jobs log
  • restore_failed_jobs - Restore failed jobs by type
  • run_jobs - Run jobs from the queue
  • run_queue_maintenance - Perform queue maintenance (unstuck jobs, remove old logs etc)

Running Jobs

This command is designed to be started and to execute jobs until a particular time limit is reached. This command supports following options:

  • --seconds (-s) - How long should one call be kept alive and execute jobs (default value is 50 seconds),
  • --channels (-c) - Channels that this command should pick jobs up from (default is main channel).

Check this example cron configuration:

*   *   *   *   *   /path/to/my/consumer run_jobs -s 180 -c main,mail

This command starts a consumer instance that listens on mail and mail channels every minute, and it is kept alive for 180 seconds. As a result, we always have three consumer instances running and executing jobs, which means that we can push quite a bit of work through them.

DI Container

All commands expect that you provide them with Interop\Container\ContainerInterface DI container with following elements:

  • log - Instance that implements \Psr\Log\LoggerInterface interface
  • dispatcher - Instance that implements \ActiveCollab\JobsQueue\DispatcherInterface interface (usually \ActiveCollab\JobsQueue\Dispatcher instance)

Commands use these instances to perform the work that they need to do and DIC offers a convenient way to inject them.