File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
pkg/enqueue/Consumption/Extension Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ public function onMessageReceived(MessageReceived $context): void
3030 {
3131 $ message = $ context ->getMessage ();
3232
33- $ context ->getLogger ()->debug ("Received from {queueName} \t {body} " , [
33+ $ context ->getLogger ()->debug ("Received from {queueName} " , [
3434 'queueName ' => $ context ->getConsumer ()->getQueue ()->getQueueName (),
3535 'redelivered ' => $ message ->isRedelivered (),
3636 'body ' => Stringify::that ($ message ->getBody ()),
@@ -45,12 +45,13 @@ public function onPostMessageReceived(PostMessageReceived $context): void
4545 $ queue = $ context ->getConsumer ()->getQueue ();
4646 $ result = $ context ->getResult ();
4747
48+ $ logMessage = "Processed from {queueName} " ;
49+
4850 $ reason = '' ;
49- $ logMessage = "Processed from {queueName} \t{body} \t{result} " ;
5051 if ($ result instanceof Result && $ result ->getReason ()) {
5152 $ reason = $ result ->getReason ();
52- $ logMessage .= ' {reason} ' ;
5353 }
54+
5455 $ logContext = [
5556 'result ' => str_replace ('enqueue. ' , '' , $ result ),
5657 'reason ' => $ reason ,
You can’t perform that action at this time.
0 commit comments