@@ -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; |