win32service/Win32ServiceBundle
1
0
Fork 0
mirror of https://github.com/win32service/Win32ServiceBundle.git synced 2026-03-24 01:02:16 +01:00
Code Issues Packages Projects Releases 10 Wiki Activity

fix failled test

Browse Source
This commit is contained in:
jb cr
2024-10-23 15:20:50 +02:00
parent 5ba4f88608
commit 2927652370
1 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
tests/Unit/MessengerIntegration/FaillureRetryMessageTest.php
View File

@@ -9,6 +9,7 @@ require_once \dirname(__DIR__, 2).'/Win32serviceState.php';
use Doctrine\DBAL\Driver\Connection;
use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;
use Symfony\Component\Messenger\MessageBusInterface;
use Win32Service\Model\AbstractServiceRunner;
use Win32Service\Model\ServiceIdentifier;
use Win32Service\Model\Win32serviceState;
use Win32ServiceBundle\Model\MessengerServiceRunner;
@@ -57,28 +58,29 @@ final class FaillureRetryMessageTest extends KernelTestCase
$runner->setServiceId(new ServiceIdentifier($serviceName));
$runner->doRun(1, 0);
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'default\'');
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'default\' AND delivered_at IS NULL');
$this->assertSame(1, (int) $c->fetchOne());
$this->assertSame(2, (int) $c->fetchOne());
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'default\' AND delivered_at IS NOT NULL');
$this->assertSame(1, (int) $c->fetchOne());
$msrRefrection = new \ReflectionClass(AbstractServiceRunner::class);
$stopRequestedProperty = $msrRefrection->getProperty('stopRequested');
$stopRequestedProperty->setAccessible(true);
Win32serviceState::reset();
$stopRequestedProperty->setValue($runner, false);
usleep(1_500_000);
$runner->doRun(1, 0);
$connexion->commit();
$connexion->beginTransaction();
for ($i = 0; $i < 3; ++$i) {
Win32serviceState::reset();
usleep(1_500_000);
$runner->doRun(1, 0);
$connexion->commit();
$connexion->beginTransaction();
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'default\'');
$this->assertSame(2, (int) $c->fetchOne());
}
$connexion->commit();
$connexion->beginTransaction();
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'failed\'');
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'default\' AND delivered_at IS NOT NULL');
$this->assertSame(1, (int) $c->fetchOne());
$c = $connexion->query('SELECT count(*) FROM messenger_messages WHERE queue_name = \'failed\' AND delivered_at IS NULL');
$this->assertSame(1, (int) $c->fetchOne());
}
}