Skip to content

Commit 08d509f

Browse files
committed
libs: fix contentEncoding as type
1 parent 7c2c47a commit 08d509f

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

src/Queue/RabbitMQQueue.php

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -76,12 +76,11 @@ public function pushRaw($payload, $queueName = null, array $options = [])
7676
$message = $this->context->createMessage($payload);
7777

7878
$message->setCorrelationId($this->getCorrelationId());
79+
$message->setContentType('application/json');
7980
$message->setDeliveryMode(AmqpMessage::DELIVERY_MODE_PERSISTENT);
8081

81-
if (isset($options['content_type'])) {
82-
$message->setPriority($options['content_type']);
83-
} else {
84-
$message->setContentType('application/json');
82+
if (isset($options['content_encoding'])) {
83+
$message->setContentEncoding($options['content_encoding']);
8584
}
8685

8786
if (isset($options['routing_key'])) {

0 commit comments

Comments
 (0)