Skip to content

Commit 0668897

Browse files
authored
Adds support for custom headers and properties on pushRaw
1 parent 075b2dd commit 0668897

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,14 @@ public function pushRaw($payload, $queueName = null, array $options = [])
7474
$message->setCorrelationId($this->getCorrelationId());
7575
$message->setContentType('application/json');
7676
$message->setDeliveryMode(AmqpMessage::DELIVERY_MODE_PERSISTENT);
77+
78+
if (isset($options['headers'])) {
79+
$message->setHeaders($options['headers']);
80+
}
81+
82+
if (isset($options['properties'])) {
83+
$message->setProperties($options['properties']);
84+
}
7785

7886
if (isset($options['attempts'])) {
7987
$message->setProperty(RabbitMQJob::ATTEMPT_COUNT_HEADERS_KEY, $options['attempts']);

0 commit comments

Comments
 (0)