insertFixtures(); $this->purgeDoctrineQueueQuery->execute( 'messenger_messages', 'webhook', new \DateTimeImmutable('2021-01-18 14:16:53', new \DateTimeZone('UTC')) ); $results = $this->fetchRemainingEntries(); Assert::assertCount(2, $results); Assert::assertContains('body', $results); Assert::assertContains('product_created', $results); } protected function setUp(): void { parent::setUp(); $this->dbalConnection = $this->get('database_connection'); $this->purgeDoctrineQueueQuery = $this->get('akeneo_messenger.query.purge'); } protected function getConfiguration(): Configuration { return $this->catalog->useMinimalCatalog(); } private function insertFixtures(): void { $sql = <<dbalConnection->executeQuery($sql); } private function fetchRemainingEntries(): array { $sql = <<dbalConnection->executeQuery($sql)->fetchFirstColumn(); } }