44 lines
1.1 KiB
PHP
44 lines
1.1 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
require_once __DIR__ . '/../vendor/autoload.php';
|
|
|
|
use App\Core\Application;
|
|
use App\Services\QueueService;
|
|
|
|
// Initialize App (loads .env, etc.)
|
|
$app = new Application(dirname(__DIR__));
|
|
|
|
echo "[*] Musadaq Queue Worker Started...\n";
|
|
|
|
// Signal handling for graceful shutdown
|
|
$keepRunning = true;
|
|
pcntl_async_signals(true);
|
|
pcntl_signal(SIGTERM, function() use (&$keepRunning) {
|
|
echo "[!] SIGTERM received, shutting down gracefully...\n";
|
|
$keepRunning = false;
|
|
});
|
|
|
|
while ($keepRunning) {
|
|
$job = QueueService::pop();
|
|
|
|
if ($job) {
|
|
echo "[+] Processing job: {$job['type']} ({$job['id']})\n";
|
|
try {
|
|
// Process based on type
|
|
// match($job['type']) { ... }
|
|
|
|
echo "[✓] Job completed: {$job['id']}\n";
|
|
} catch (\Throwable $e) {
|
|
echo "[✗] Job failed: {$job['id']} - {$e->getMessage()}\n";
|
|
// Handle retries or DLQ
|
|
}
|
|
} else {
|
|
// Sleep if no jobs
|
|
usleep(500000); // 0.5s
|
|
}
|
|
}
|
|
|
|
echo "[*] Worker stopped.\n";
|