diff --git a/pkg/enqueue/Consumption/Extension/LogExtension.php b/pkg/enqueue/Consumption/Extension/LogExtension.php index 14383c4d1..6338ad314 100644 --- a/pkg/enqueue/Consumption/Extension/LogExtension.php +++ b/pkg/enqueue/Consumption/Extension/LogExtension.php @@ -30,7 +30,7 @@ public function onMessageReceived(MessageReceived $context): void { $message = $context->getMessage(); - $context->getLogger()->debug("Received from {queueName}\t{body}", [ + $context->getLogger()->debug('Received from {queueName}', [ 'queueName' => $context->getConsumer()->getQueue()->getQueueName(), 'redelivered' => $message->isRedelivered(), 'body' => Stringify::that($message->getBody()), @@ -45,12 +45,13 @@ public function onPostMessageReceived(PostMessageReceived $context): void $queue = $context->getConsumer()->getQueue(); $result = $context->getResult(); + $logMessage = 'Processed from {queueName}'; + $reason = ''; - $logMessage = "Processed from {queueName}\t{body}\t{result}"; if ($result instanceof Result && $result->getReason()) { $reason = $result->getReason(); - $logMessage .= ' {reason}'; } + $logContext = [ 'result' => str_replace('enqueue.', '', $result), 'reason' => $reason, diff --git a/pkg/enqueue/Tests/Client/ConsumptionExtension/LogExtensionTest.php b/pkg/enqueue/Tests/Client/ConsumptionExtension/LogExtensionTest.php index db757676b..383ec4d9b 100644 --- a/pkg/enqueue/Tests/Client/ConsumptionExtension/LogExtensionTest.php +++ b/pkg/enqueue/Tests/Client/ConsumptionExtension/LogExtensionTest.php @@ -91,7 +91,7 @@ public function testShouldLogMessageReceived() $logger ->expects($this->once()) ->method('debug') - ->with('Received from {queueName} {body}', [ + ->with('Received from {queueName}', [ 'queueName' => 'aQueue', 'redelivered' => false, 'body' => Stringify::that('aBody'), @@ -118,7 +118,7 @@ public function testShouldLogMessageProcessedWithStringResult() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -148,7 +148,7 @@ public function testShouldLogRejectedMessageAsError() ->expects($this->once()) ->method('log') ->with(LogLevel::ERROR, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -178,7 +178,7 @@ public function testShouldLogMessageProcessedWithResultObject() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -208,7 +208,7 @@ public function testShouldLogMessageProcessedWithReasonResultObject() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result} {reason}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), diff --git a/pkg/enqueue/Tests/Consumption/Extension/LogExtensionTest.php b/pkg/enqueue/Tests/Consumption/Extension/LogExtensionTest.php index 006a2c549..01b29f0c0 100644 --- a/pkg/enqueue/Tests/Consumption/Extension/LogExtensionTest.php +++ b/pkg/enqueue/Tests/Consumption/Extension/LogExtensionTest.php @@ -85,7 +85,7 @@ public function testShouldLogMessageReceived() $logger ->expects($this->once()) ->method('debug') - ->with('Received from {queueName} {body}', [ + ->with('Received from {queueName}', [ 'queueName' => 'aQueue', 'redelivered' => false, 'body' => Stringify::that('aBody'), @@ -112,7 +112,7 @@ public function testShouldLogMessageProcessedWithStringResult() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -142,7 +142,7 @@ public function testShouldLogRejectedMessageAsError() ->expects($this->once()) ->method('log') ->with(LogLevel::ERROR, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -172,7 +172,7 @@ public function testShouldLogMessageProcessedWithResultObject() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'), @@ -202,7 +202,7 @@ public function testShouldLogMessageProcessedWithReasonResultObject() ->expects($this->once()) ->method('log') ->with(LogLevel::INFO, - 'Processed from {queueName} {body} {result} {reason}', + 'Processed from {queueName}', [ 'queueName' => 'aQueue', 'body' => Stringify::that('aBody'),