Skip to content

Commit bd8bdd3

Browse files
committed
[consumption] Make QueueConsumer final
1 parent 7492f40 commit bd8bdd3

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

Diff for: pkg/enqueue/Consumption/QueueConsumer.php

+3-3
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
use Interop\Queue\PsrQueue;
1616
use Psr\Log\NullLogger;
1717

18-
class QueueConsumer
18+
final class QueueConsumer
1919
{
2020
/**
2121
* @var PsrContext
@@ -268,7 +268,7 @@ public function consume(ExtensionInterface $runtimeExtension = null)
268268
*
269269
* @return bool
270270
*/
271-
protected function doConsume(ExtensionInterface $extension, Context $context)
271+
private function doConsume(ExtensionInterface $extension, Context $context)
272272
{
273273
$processor = $context->getPsrProcessor();
274274
$consumer = $context->getPsrConsumer();
@@ -334,7 +334,7 @@ protected function doConsume(ExtensionInterface $extension, Context $context)
334334
*
335335
* @throws \Exception
336336
*/
337-
protected function onInterruptionByException(ExtensionInterface $extension, Context $context)
337+
private function onInterruptionByException(ExtensionInterface $extension, Context $context)
338338
{
339339
$logger = $context->getLogger();
340340
$logger->error(sprintf('Consuming interrupted by exception'));

0 commit comments

Comments
 (0)