diff --git a/lib/winston-logstash.js b/lib/winston-logstash.js
index 0aab5f1..85132d9 100644
--- a/lib/winston-logstash.js
+++ b/lib/winston-logstash.js
@@ -137,7 +137,7 @@ Logstash.prototype.sendLog = function (message, callback) {
   var self = this;
   callback = callback || function () {};
 
-  self.socket.write(message);
+  self.socket.write(message + '\n');
   callback();
 };
 
diff --git a/test/winston-logstash_test.js b/test/winston-logstash_test.js
index 3d5c1ed..4438262 100644
--- a/test/winston-logstash_test.js
+++ b/test/winston-logstash_test.js
@@ -40,13 +40,27 @@ describe('winston-logstash transport', function() {
       done();
     });
 
-    it('send logs over TCP', function(done) {
+    it('send logs over TCP as valid json', function(done) {
       var response;
       var logger = createLogger(port);
+      var expected = {"stream":"sample","level":"info","message":"hello world"};
 
       test_server = createTestServer(port, function (data) {
         response = data.toString();
-        expect(response).to.be.equal('{"stream":"sample","level":"info","message":"hello world"}');
+        expect(JSON.parse(response)).to.be.eql(expected);
+        done();
+      });
+
+      logger.log('info', 'hello world', {stream: 'sample'});
+    });
+
+    it('send each log with a new line character', function(done) {
+      var response;
+      var logger = createLogger(port);
+
+      test_server = createTestServer(port, function (data) {
+        response = data.toString();
+        expect(response).to.be.equal('{"stream":"sample","level":"info","message":"hello world"}\n');
         done();
       });