diff --git a/index.js b/index.js index f6c73867a233fbc4ac6905fa29fdd438e392a8eb..81052067db4a5e7c954fa031a5d58e3b1b5f06c0 100644 --- a/index.js +++ b/index.js @@ -128,10 +128,17 @@ function Log (options) { facility: this.name, level:tag })) - graylog.send(buffed, this.options.graylog.port, this.options.graylog.server, function(error){ - if (error) { - console.error(error) - } + graylog.connect(this.options.graylog.port, this.options.graylog.server, (err) => { + if (err) { + console.error(err) + } else { + graylog.send(buffed, (error) => { + if (error) { + console.error(error) + } + graylog.close(); + }) + } }) } return msg