@@ -36,7 +36,7 @@ discard block |
||
36 | 36 | */ |
37 | 37 | public function readArguments(array $args, array $message) |
38 | 38 | { |
39 | - $envelope = array_filter($args, function ($item) use ($message) { |
|
39 | + $envelope = array_filter($args, function($item) use ($message) { |
|
40 | 40 | return $item instanceof $message['message_fqcn']; |
41 | 41 | }); |
42 | 42 | if ($envelope) { |
@@ -106,14 +106,14 @@ discard block |
||
106 | 106 | */ |
107 | 107 | private function handleHeaders(array $args, array $message, $envelope) |
108 | 108 | { |
109 | - $headers = array_filter($args, function ($item) use ($message) { |
|
109 | + $headers = array_filter($args, function($item) use ($message) { |
|
110 | 110 | return $item instanceof $message['headers_fqcn']; |
111 | 111 | }); |
112 | 112 | if ($headers) { |
113 | 113 | $envelope->setHeader(reset($headers)); |
114 | 114 | } else { |
115 | 115 | |
116 | - $headers = array_filter($args, function ($item) { |
|
116 | + $headers = array_filter($args, function($item) { |
|
117 | 117 | return $item instanceof Header; |
118 | 118 | }); |
119 | 119 | if (count($headers)) { |
@@ -132,7 +132,7 @@ discard block |
||
132 | 132 | } |
133 | 133 | } |
134 | 134 | |
135 | - $args = array_filter($args, function ($item) use ($message) { |
|
135 | + $args = array_filter($args, function($item) use ($message) { |
|
136 | 136 | return !($item instanceof Header) && !($item instanceof $message['headers_fqcn']); |
137 | 137 | }); |
138 | 138 | return $args; |