Xervice\LogRabbitMq\Business\Plugin\Queue\AbstractLogQueueListener::handleMessage()

Complexity

Conditions	3
Paths	3

Size

Total Lines	10
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	3

Importance

Changes

0

<?php
    public function handleMessage(
        RabbitMqMessageCollectionDataProvider $collectionDataProvider,
        AMQPChannel $channel
    ): void {
        foreach ($collectionDataProvider->getMessages() as $message) {
            if ($message->getMessage() instanceof LogMessageDataProvider) {
                $this->handleLog($message->getMessage());
            }

            $this->sendAck($channel, $message);
        }
}