10000 fix integration tests · symfony/symfony@f836b55 · GitHub
[go: up one dir, main page]

Skip to content

Commit f836b55

Browse files
fix integration tests
1 parent a4a3002 commit f836b55

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/Symfony/Component/Messenger/Tests/Adapter/AmqpExt/AmqpExtIntegrationTest.php

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,9 +116,15 @@ public function testItSupportsTimeoutAndTicksNullMessagesToTheHandler()
116116
$connection->queue()->purge();
117117

118118
$sender = new AmqpSender($serializer, $connection);
119-
$receiver = new MaximumCountReceiver(new AmqpReceiver($serializer, $connection), 2);
120-
$receiver->receive(function ($message) {
119+
$receiver = new AmqpReceiver($serializer, $connection);
120+
121+
$receivedMessages = 0;
122+
$receiver->receive(function ($message) use ($receiver, &$receivedMessages) {
121123
$this->assertNull($message);
124+
125+
if (2 == ++$receivedMessages) {
126+
$receiver->stop();
127+
}
122128
});
123129
}
124130

0 commit comments

Comments
 (0)
0