Convert GelfMessage into string required by createAmqpMessage (#1869)

* Convert GelfMessage into string required by createAmqpMessage

* Convert object on write() too

src/Monolog/Handler/AmqpHandler.php

@@ -11,6 +11,7 @@
 
 namespace Monolog\Handler;
 
+use Gelf\Message as GelfMessage;
 use Monolog\Level;
 use Monolog\Formatter\FormatterInterface;
 use Monolog\Formatter\JsonFormatter;
@@ -75,6 +76,10 @@ protected function write(LogRecord $record): void
         $data = $record->formatted;
         $routingKey = $this->getRoutingKey($record);
 
+        if($data instanceof GelfMessage) {
+            $data = json_encode($data->toArray());
+        }
+
         if ($this->exchange instanceof AMQPExchange) {
             $attributes = [
                 'delivery_mode' => 2,
@@ -117,6 +122,10 @@ public function handleBatch(array $records): void
             $record = $this->processRecord($record);
             $data = $this->getFormatter()->format($record);
 
+            if($data instanceof GelfMessage) {
+                $data = json_encode($data->toArray());
+            }
+
             $this->exchange->batch_basic_publish(
                 $this->createAmqpMessage($data),
                 $this->exchangeName,