diff --git a/src/app/Handlers/RabbitMQHandler.php b/src/app/Handlers/RabbitMQHandler.php index 1d76340..922cabb 100644 --- a/src/app/Handlers/RabbitMQHandler.php +++ b/src/app/Handlers/RabbitMQHandler.php @@ -4,6 +4,7 @@ namespace Ae3\LaravelLogsLayer\app\Handlers; use Exception; use Monolog\Handler\AbstractProcessingHandler; +use Monolog\LogRecord; use PhpAmqpLib\Channel\AbstractChannel; use PhpAmqpLib\Channel\AMQPChannel; use PhpAmqpLib\Connection\AMQPStreamConnection; @@ -49,12 +50,12 @@ class RabbitMQHandler extends AbstractProcessingHandler } /** - * @param array $record + * @param LogRecord $record * @return void */ - public function write(array $record): void + public function write(LogRecord $record): void { - $data = json_encode($record); + $data = json_encode($record->toArray()); $msg = new AMQPMessage($data, [ 'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT ]);