File tree Expand file tree Collapse file tree 2 files changed +0
-21
lines changed
src/Symfony/Component/Messenger Expand file tree Collapse file tree 2 files changed +0
-21
lines changed Original file line number Diff line number Diff line change @@ -584,25 +584,6 @@ public function testFlushBatchOnStop()
584584
585585 $ this ->assertSame ($ expectedMessages , $ handler ->processedMessages );
586586 }
587-
588- public function testGcCollectCyclesIsCalledOnMessageHandle ()
589- {
590- $ apiMessage = new DummyMessage ('API ' );
591-
592- $ receiver = new DummyReceiver ([[new Envelope ($ apiMessage )]]);
593-
594- $ bus = $ this ->createMock (MessageBusInterface::class);
595-
596- $ dispatcher = new EventDispatcher ();
597- $ dispatcher ->addSubscriber (new StopWorkerOnMessageLimitListener (1 ));
598-
599- $ worker = new Worker (['transport ' => $ receiver ], $ bus , $ dispatcher );
600- $ worker ->run ();
601-
602- $ gcStatus = gc_status ();
603-
604- $ this ->assertGreaterThan (0 , $ gcStatus ['runs ' ]);
605- }
606587}
607588
608589class DummyQueueReceiver extends DummyReceiver implements QueueReceiverInterface
Original file line number Diff line number Diff line change @@ -117,8 +117,6 @@ public function run(array $options = []): void
117117 // this should prevent multiple lower priority receivers from
118118 // blocking too long before the higher priority are checked
119119 if ($ envelopeHandled ) {
120- gc_collect_cycles ();
121-
122120 break ;
123121 }
124122 }
You can’t perform that action at this time.
0 commit comments