diff --git a/src/app/Handlers/RabbitMQHandler.php b/src/app/Handlers/RabbitMQHandler.php index 775e488..fc65094 100644 --- a/src/app/Handlers/RabbitMQHandler.php +++ b/src/app/Handlers/RabbitMQHandler.php @@ -77,7 +77,7 @@ class RabbitMQHandler extends AbstractProcessingHandler { $data = json_encode($record); $msg = new AMQPMessage($data, [ - 'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT + 'delivery_mode' => 2 ]); $this->channel->basic_publish($msg, $this->exchange, $this->routingKey);