From 3ea642268534fac8bd932b92f30e2f28c3e7f804 Mon Sep 17 00:00:00 2001 From: Sergey Maskalik Date: Mon, 12 Oct 2015 12:56:14 -0700 Subject: [PATCH 1/2] Add missing category field Current logstashUDP appender doesn't send category of the loggingEvent which is very useful when filtering for logs. --- lib/appenders/logstashUDP.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/appenders/logstashUDP.js b/lib/appenders/logstashUDP.js index 9ac5579..1db71af 100644 --- a/lib/appenders/logstashUDP.js +++ b/lib/appenders/logstashUDP.js @@ -21,7 +21,8 @@ function logstashUDP (config, layout) { '@timestamp': (new Date(loggingEvent.startTime)).toISOString(), type: type, message: logMessage, - fields: fields + fields: fields, + category: loggingEvent.logger.category }; sendLog(udp, config.host, config.port, logObject); }; From 84611d99633238c4a082c8c1970158e613f4f3bc Mon Sep 17 00:00:00 2001 From: Sergey Maskalik Date: Mon, 12 Oct 2015 14:00:21 -0700 Subject: [PATCH 2/2] Add test for category --- test/logstashUDP-test.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/test/logstashUDP-test.js b/test/logstashUDP-test.js index 37f2b47..97bfe68 100644 --- a/test/logstashUDP-test.js +++ b/test/logstashUDP-test.js @@ -42,7 +42,7 @@ function setupLogging(category, options) { vows.describe('logstashUDP appender').addBatch({ 'when logging with logstash via UDP': { topic: function() { - var setup = setupLogging('logstashUDP', { + var setup = setupLogging('myCategory', { "host": "127.0.0.1", "port": 10001, "type": "logstashUDP", @@ -73,6 +73,7 @@ vows.describe('logstashUDP appender').addBatch({ }; assert.equal(JSON.stringify(json.fields), JSON.stringify(fields)); assert.equal(json.message, 'Log event #1'); + assert.equal(json.category, 'myCategory'); // Assert timestamp, up to hours resolution. var date = new Date(json['@timestamp']); assert.equal(