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()
584
584
585
585
$ this ->assertSame ($ expectedMessages , $ handler ->processedMessages );
586
586
}
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
- }
606
587
}
607
588
608
589
class 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
117
117
// this should prevent multiple lower priority receivers from
118
118
// blocking too long before the higher priority are checked
119
119
if ($ envelopeHandled ) {
120
- gc_collect_cycles ();
121
-
122
120
break ;
123
121
}
124
122
}
You can’t perform that action at this time.
0 commit comments