|
13 | 13 |
|
14 | 14 | use Doctrine\DBAL\Configuration;
|
15 | 15 | use Doctrine\DBAL\DriverManager;
|
16 |
| -use Doctrine\DBAL\Result; |
17 | 16 | use Doctrine\DBAL\Schema\AbstractSchemaManager;
|
18 | 17 | use Doctrine\DBAL\Schema\DefaultSchemaManagerFactory;
|
19 | 18 | use Doctrine\DBAL\Tools\DsnParser;
|
@@ -59,18 +58,14 @@ public function testSendWithDelay()
|
59 | 58 | {
|
60 | 59 | $this->connection->send('{"message": "Hi i am delayed"}', ['type' => DummyMessage::class], 600000);
|
61 | 60 |
|
62 |
| - $stmt = $this->driverConnection->createQueryBuilder() |
| 61 | + $result = $this->driverConnection->createQueryBuilder() |
63 | 62 | ->select('m.available_at')
|
64 | 63 | ->from('messenger_messages', 'm')
|
65 | 64 | ->where('m.body = :body')
|
66 |
| - ->setParameter('body', '{"message": "Hi i am delayed"}'); |
67 |
| - if (method_exists($stmt, 'executeQuery')) { |
68 |
| - $stmt = $stmt->executeQuery(); |
69 |
| - } else { |
70 |
| - $stmt = $stmt->execute(); |
71 |
| - } |
| 65 | + ->setParameter('body', '{"message": "Hi i am delayed"}') |
| 66 | + ->executeQuery(); |
72 | 67 |
|
73 |
| - $available_at = new \DateTimeImmutable($stmt instanceof Result ? $stmt->fetchOne() : $stmt->fetchColumn()); |
| 68 | + $available_at = new \DateTimeImmutable($result->fetchOne()); |
74 | 69 |
|
75 | 70 | $now = new \DateTimeImmutable('now + 60 seconds');
|
76 | 71 | $this->assertGreaterThan($now, $available_at);
|
@@ -186,7 +181,7 @@ public function testTheTransportIsSetupOnGet()
|
186 | 181 | $this->assertEquals('the body', $envelope['body']);
|
187 | 182 | }
|
188 | 183 |
|
189 |
| - private function formatDateTime(\DateTimeImmutable $dateTime) |
| 184 | + private function formatDateTime(\DateTimeImmutable $dateTime): string |
190 | 185 | {
|
191 | 186 | return $dateTime->format($this->driverConnection->getDatabasePlatform()->getDateTimeFormatString());
|
192 | 187 | }
|
|
0 commit comments