fixes

dgafka · dgafka · commit ed7d6b13c695 · 2026-01-25T18:45:18.000+01:00
diff --git a/packages/Laravel/tests/Application/Execution/LaravelQueueIntegrationTest.php b/packages/Laravel/tests/Application/Execution/LaravelQueueIntegrationTest.php
@@ -355,7 +355,8 @@ public function test_sending_with_delay()
         $messaging->sendCommandWithRoutingKey('execute.example_command', $messagePayload, metadata: [
             MessageHeaders::DELIVERY_DELAY => 1000,
         ]);
-        $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup(maxExecutionTimeInMilliseconds: 2000));
+        sleep(2);
+        $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup());
         $this->assertCount(1, $messaging->sendQueryWithRouting('consumer.getMessages'));
     }
 
diff --git a/packages/Symfony/tests/phpunit/MessengerIntegrationTest.php b/packages/Symfony/tests/phpunit/MessengerIntegrationTest.php
@@ -310,7 +310,8 @@ public function test_sending_with_delay()
         $messaging->sendCommandWithRoutingKey('execute.example_command', $messagePayload, metadata: [
             MessageHeaders::DELIVERY_DELAY => 1000,
         ]);
-        $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup(maxExecutionTimeInMilliseconds: 2000));
+        sleep(2);
+        $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup());
         $this->assertCount(1, $messaging->sendQueryWithRouting('consumer.getMessages'));
     }
 

Original file line number	Diff line number	Diff line change
`@@ -355,7 +355,8 @@ public function test_sending_with_delay()`
`355`	`355`	`$messaging->sendCommandWithRoutingKey('execute.example_command', $messagePayload, metadata: [`
`356`	`356`	`MessageHeaders::DELIVERY_DELAY => 1000,`
`357`	`357`	`]);`
`358`		`- $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup(maxExecutionTimeInMilliseconds: 2000));`
	`358`	`+ sleep(2);`
	`359`	`+ $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup());`
`359`	`360`	`$this->assertCount(1, $messaging->sendQueryWithRouting('consumer.getMessages'));`
`360`	`361`	`}`
`361`	`362`
Original file line number	Diff line number	Diff line change
`@@ -310,7 +310,8 @@ public function test_sending_with_delay()`
`310`	`310`	`$messaging->sendCommandWithRoutingKey('execute.example_command', $messagePayload, metadata: [`
`311`	`311`	`MessageHeaders::DELIVERY_DELAY => 1000,`
`312`	`312`	`]);`
`313`		`- $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup(maxExecutionTimeInMilliseconds: 2000));`
	`313`	`+ sleep(2);`
	`314`	`+ $messaging->run($channelName, ExecutionPollingMetadata::createWithTestingSetup());`
`314`	`315`	`$this->assertCount(1, $messaging->sendQueryWithRouting('consumer.getMessages'));`
`315`	`316`	`}`
`316`	`317`