We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 23f2038 commit ea2a998Copy full SHA for ea2a998
pkg/rdkafka/Client/RdKafkaDriver.php
@@ -70,15 +70,13 @@ public function createClientMessage(PsrMessage $message)
70
$clientMessage->setHeaders($message->getHeaders());
71
$clientMessage->setProperties($message->getProperties());
72
73
+ $clientMessage->setContentType($message->getHeader('content_type'));
74
+
75
$clientMessage->setTimestamp($message->getTimestamp());
76
$clientMessage->setMessageId($message->getMessageId());
77
$clientMessage->setReplyTo($message->getReplyTo());
78
$clientMessage->setCorrelationId($message->getCorrelationId());
79
- if ($contentType = $message->getHeader('content_type')) {
- $clientMessage->setContentType($contentType);
80
- }
81
-
82
return $clientMessage;
83
}
84
0 commit comments