Repository files navigation

NOTE: This is experimental, you might not need it

Robust Redis-backed background job processing for WordPress. Provides prioritized, delayed, and retryable jobs with an admin UI, REST API, token-based auth (scopes + rate limiting), and extensibility for custom job types.

A production-ready queue system for WordPress, following best practices and patterns.

Core:

• Priority + delayed + retryable jobs
• Redis (phpredis or Predis) abstraction
• Memory/timeouts and job metadata persistence

Built‑in Jobs:

• Email delivery (single/bulk)
• Image processing (thumbnails, optimization)
• Generic API / webhook style jobs

Interfaces:

• Admin dashboard (stats, browser, test tools, purge, debug)
• REST API (create jobs, trigger worker, health, stats)

Security & Control:

• Capability or API token auth
• Token scopes (worker,full)
• Per-token rate limiting
• Structured request logging with rotation

Extensibility:

• SimpleAbstract_Base_Job subclassing
• Filters for dynamic job instantiation

TL;DR: seedocs/README.md for overview,docs/usage.md for operations, anddocs/extending-jobs.md for custom jobs.

• Bulk email sending (newsletters, notifications)
• Transactional emails (order confirmations, password resets)
• Email campaign processing
• Benefits: Prevents timeouts, improves user experience, handles SMTP failures gracefully

• Thumbnail generation for multiple sizes
• Image optimization (compression, format conversion)
• Watermark application
• Benefits: Reduces page load times, prevents memory exhaustion

• CSV/XML imports (products, users, posts)
• Database migrations
• Content synchronization between sites
• Benefits: Handles large datasets without timeout issues

• Search index updates (Elasticsearch, Algolia)
• Cache warming after content updates
• Content analysis (SEO scoring, readability)
• Benefits: Keeps content fresh without blocking user interactions

• Social media posting (Facebook, Twitter, LinkedIn)
• CRM synchronization (Salesforce, HubSpot)
• Analytics data collection (Google Analytics, custom tracking)
• Benefits: Handles API rate limits and failures gracefully

• Order processing workflows
• Inventory synchronization
• Payment verification processes
• Benefits: Ensures order integrity and improves checkout experience

• Scheduled post publishing
• Content distribution to multiple platforms
• SEO metadata generation
• Benefits: Reliable scheduling and cross-platform consistency

• User registration workflows
• Profile data enrichment
• Permission updates across systems

• Database backups
• File system backups
• Remote backup uploads

• Report generation
• Data aggregation
• Performance metrics calculation

1. WordPress: Version 6.7 or higher
2. PHP: Version 8.3 or higher
3. Redis Server: Running Redis instance
4. Redis PHP Extension ORPredis Library: One of these for Redis connectivity

# Ubuntu/Debiansudo apt-get install php-redis# macOS with Homebrewbrew install php-redis# CentOS/RHELsudo yum install php-redis

# In your WordPress root or plugin directorycomposer require predis/predis

• Quick Install

  • Downloadredis-queue.zip
  • Upload via Plugins > Add New > Upload Plugin
  • Activate the plugin.

• Composer Install

  composer require soderlind/redis-queue

• Updates

  • Pluginupdates are handled automatically via GitHub. No need to manually download and install updates.

Navigate toRedis Queue > Settings in your WordPress admin to configure:

• Redis Host: Your Redis server hostname (default: 127.0.0.1)
• Redis Port: Redis server port (default: 6379)
• Redis Database: Database number 0-15 (default: 0)
• Redis Password: Authentication password (if required)
• Worker Timeout: Maximum job execution time (default: 30 seconds)
• Max Retries: Failed job retry attempts (default: 3)
• Retry Delay: Base delay between retries (default: 60 seconds)
• Batch Size: Jobs per worker execution (default: 10)

You can also configure via environment variables or wp-config.php:

// wp-config.phpdefine('REDIS_QUEUE_HOST','127.0.0.1' );define('REDIS_QUEUE_PORT',6379 );define('REDIS_QUEUE_PASSWORD','your-password' );define('REDIS_QUEUE_DATABASE',0 );

• View real-time queue statistics
• Monitor system health
• Trigger workers manually
• View job processing results

• Browse all jobs with filtering
• View detailed job information
• Cancel queued or failed jobs
• Monitor job status changes

Create test jobs to verify functionality:

Email Job Example:

Type: Single EmailTo: admin@example.comSubject: Test EmailMessage: Testing Redis queue system

Image Processing Example:

Operation: Generate ThumbnailsAttachment ID: 123Sizes: thumbnail, medium, large

API Sync Example:

Operation: WebhookURL: https://httpbin.org/postData: {"test": "message"}

1. Install a Redis server (or use existing) and ensure the phpredis extensionor Predis library is available.
2. Clone intowp-content/plugins/ and activate.
3. Configure Redis + queue settings under:Redis Queue → Settings.
4. Create a test job via the admin Test interface or REST API.
5. Run workers manually (admin button) or on a schedule (cron / wp-cli / external runner).

git clone https://github.com/soderlind/redis-queue.git wp-content/plugins/redis-queue

Optionally add Predis:

composer require predis/predis

Define environment constants (optional) inwp-config.php:

define('REDIS_QUEUE_PORT',6379 );define('REDIS_QUEUE_DATABASE',0 );

Then enqueue a job programmatically:

useSoderlind\RedisQueue\Jobs\Email_Job;$job =newEmail_Job(['email_type' =>'single','to' =>'admin@example.com','subject' =>'Hello','message' =>'Testing queue']);redis_queue()->queue_manager->enqueue($job );

Process jobs:

redis_queue_process_jobs();// helper or via admin UI

See Usage & REST docs for deeper examples.

Use this plugin to offload expensive or slow tasks: emails, media transformations, API calls, data synchronization, indexing, cache warming, and other background workloads that should not block page loads.

• WordPress plugin bootstrap registers queue manager + job processor
• Redis stores queue + delayed sets; MySQL stores durable job records
• Synchronous worker invoked via admin, REST, or scheduled execution
• Job lifecycle: queued → (delayed ready) → processing → success/failure (with retry window)
• Filters allow custom job class instantiation by type

1. Default capability check (manage_options).
2. Optional API token (bearer header) with: scope, rate limiting, request logging.
3. Filters to customize allowed routes per scope.

Full details: see theREST API documentation.

Implement a subclass ofAbstract_Base_Job, overrideget_job_type() +execute(), optionallyshould_retry() andhandle_failure(). Register dynamically with theredis_queue_create_job filter. Full guide:Extending Jobs.

Examples:

# Cron (every minute)***** wpeval"redis_queue()->process_jobs();"

For higher throughput run multiple workers targeting distinct queues.

• WordPress 6.7+
• PHP 8.3+
• Redis server
• phpredis extension OR Composer + Predis

Contributions welcome. Please fork, branch, commit with clear messages, and open a PR. Add tests or reproducible steps for behavior changes.

GPL v2 or later. SeeLICENSE.

Made with ❤️ byPer Søderlind

For detailed usage, advanced features, troubleshooting, and performance tuning visit theUsage guide. Additional topics:Scaling,Maintenance.