Michael Schiemer
55a330b223
- Add DISCOVERY_LOG_LEVEL=debug - Add DISCOVERY_SHOW_PROGRESS=true - Temporary changes for debugging InitializerProcessor fixes on production
69 lines
1.6 KiB
PHP
69 lines
1.6 KiB
PHP
#!/usr/bin/env php
|
|
<?php
|
|
|
|
use App\Framework\CommandBus\CommandBus;
|
|
use App\Framework\Console\ConsoleOutput;
|
|
use App\Framework\Core\AppBootstrapper;
|
|
use App\Framework\Queue\FileQueue;
|
|
|
|
require __DIR__ . '/vendor/autoload.php';
|
|
require __DIR__ . '/src/Framework/Debug/helpers.php';
|
|
|
|
$bootstrapper = new AppBootstrapper(getcwd(), new \App\Framework\Performance\PerformanceCollector(false));
|
|
$container = $bootstrapper->bootstrapWorker();
|
|
|
|
$queue = new \App\Framework\Queue\RedisQueue('commands', 'redis');
|
|
|
|
$worker = new \App\Framework\Worker\Worker(
|
|
$container,
|
|
$queue, #new FileQueue(__DIR__ . '/src/Framework/CommandBus/storage/queue/'),
|
|
$container->get(CommandBus::class),
|
|
$container->get(ConsoleOutput::class),
|
|
);
|
|
|
|
pcntl_signal(SIGTERM, function () use ($worker) {
|
|
$worker->stop();
|
|
});
|
|
|
|
pcntl_signal(SIGINT, function () use ($worker) {
|
|
$worker->stop();
|
|
});
|
|
|
|
$worker->start();
|
|
|
|
|
|
|
|
/*
|
|
$queue = new FileQueue(__DIR__ . '/src/Framework/CommandBus/storage/queue/');
|
|
|
|
error_log('Worker started');
|
|
|
|
error_log(__DIR__ . '/src/Framework/CommandBus/storage/queue');
|
|
|
|
#$commandBus = $container->get(CommandBus::class);
|
|
|
|
#$commandBus->dispatch(new \App\Application\Newsletter\SignUp\SignupUserToNewsletter('Michael', 'mail'));
|
|
|
|
#var_dump($queue);
|
|
|
|
while (true) {
|
|
$job = $queue->pop();
|
|
|
|
if ($job) {
|
|
try {
|
|
// Job verarbeiten
|
|
|
|
#$commandBus->handle($job);
|
|
|
|
error_log('handled: ' . $job::class);
|
|
|
|
#(new JobProcessor())->handle($job);
|
|
} catch (\Throwable $e) {
|
|
// Fehler-Handling / Retry-Logik
|
|
}
|
|
} else {
|
|
// Leerlauf-Pause, z.B. 100 ms
|
|
usleep(100_000);
|
|
}
|
|
}*/
|