Skip to content

Commit

Permalink
Fix headers in KafkaReceiver.php on line 64.
Browse files Browse the repository at this point in the history
This issue can be reproduced if you use your package on one side and srooze enqueue on other side.

It fixes, because you use declare(strict_types=1):
[ErrorException]
Notice: Undefined property: RdKafka\Message::$headers
  • Loading branch information
fractalzombie committed Oct 24, 2021
1 parent 6471a18 commit 6feaf44
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/Messenger/KafkaReceiver.php
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ public function get(): iterable

$envelope = $this->serializer->decode([
'body' => $message->payload,
'headers' => $message->headers,
'headers' => $message->headers ?? [],
'key' => $message->key,
'offset' => $message->offset,
'timestamp' => $message->timestamp,
Expand Down

0 comments on commit 6feaf44

Please sign in to comment.