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
30
30
{
31
31
$ message = $ context ->getMessage ();
32
32
33
- $ context ->getLogger ()->debug ("Received from {queueName} \t {body} " , [
33
+ $ context ->getLogger ()->debug ("Received from {queueName} " , [
34
34
'queueName ' => $ context ->getConsumer ()->getQueue ()->getQueueName (),
35
35
'redelivered ' => $ message ->isRedelivered (),
36
36
'body ' => Stringify::that ($ message ->getBody ()),
@@ -45,12 +45,13 @@ public function onPostMessageReceived(PostMessageReceived $context): void
45
45
$ queue = $ context ->getConsumer ()->getQueue ();
46
46
$ result = $ context ->getResult ();
47
47
48
+ $ logMessage = "Processed from {queueName} " ;
49
+
48
50
$ reason = '' ;
49
- $ logMessage = "Processed from {queueName} \t{body} \t{result} " ;
50
51
if ($ result instanceof Result && $ result ->getReason ()) {
51
52
$ reason = $ result ->getReason ();
52
- $ logMessage .= ' {reason} ' ;
53
53
}
54
+
54
55
$ logContext = [
55
56
'result ' => str_replace ('enqueue. ' , '' , $ result ),
56
57
'reason ' => $ reason ,
You can’t perform that action at this time.
0 commit comments