diff --git a/src/Monolog/Formatter/LogstashFormatter.php b/src/Monolog/Formatter/LogstashFormatter.php index f74485fc..938b595b 100644 --- a/src/Monolog/Formatter/LogstashFormatter.php +++ b/src/Monolog/Formatter/LogstashFormatter.php @@ -83,6 +83,9 @@ class LogstashFormatter extends NormalizerFormatter if (isset($record['level_name'])) { $message['level'] = $record['level_name']; } + if (isset($record['level'])) { + $message['level_num'] = $record['level']; + } if ($this->applicationName) { $message['type'] = $this->applicationName; } diff --git a/tests/Monolog/Formatter/LogstashFormatterTest.php b/tests/Monolog/Formatter/LogstashFormatterTest.php index 57d67592..cfe67a42 100644 --- a/tests/Monolog/Formatter/LogstashFormatterTest.php +++ b/tests/Monolog/Formatter/LogstashFormatterTest.php @@ -45,6 +45,7 @@ class LogstashFormatterTest extends \PHPUnit_Framework_TestCase $this->assertEquals('log', $message['message']); $this->assertEquals('meh', $message['channel']); $this->assertEquals('ERROR', $message['level']); + $this->assertEquals(Logger::ERROR, $message['level_num']); $this->assertEquals('test', $message['type']); $this->assertEquals('hostname', $message['host']);