diff --git a/src/QMPClient.ts b/src/QMPClient.ts
index 796fa80..c2b5b67 100644
--- a/src/QMPClient.ts
+++ b/src/QMPClient.ts
@@ -46,50 +46,52 @@ export default class QMPClient extends EventEmitter {
     }
 
     private async onData(data : Buffer) {
-        let msgraw = data.toString();
-        let msg;
+        let msgraw = data.toString().split("\n");
+        for(var message in msgraw) {
+            let msg;
 
-        try {
-            msg = JSON.parse(msgraw);
-        } catch {
-            this.emit("qmpreturn", '');
-            return;
-        }
-
-        if (msg.QMP !== undefined) {
-            if (this.sentConnected) 
+            try {
+                msg = JSON.parse(msgraw[message]);
+            } catch {
+                this.emit("qmpreturn", "");
                 return;
-                
-            await this.execute({ execute: "qmp_capabilities" });
-
-            this.emit('connected');
-            this.sentConnected = true;
-        }
-        if (msg.return !== undefined)
-            this.emit("qmpreturn", msg.return);
-        else if(msg.event !== undefined) {
-            switch(msg.event) {
-                case "STOP":
-                {
-                    log("INFO", "The VM was shut down, restarting...");
-                    this.reboot();
-                    break;
-                }
-                case "RESET":
-                {
-                    log("INFO", "QEMU reset event occured");
-                    this.resume();
-                    break;
-                };
-                default: {
-                    this.emit("qmpreturn", '');
-                    break;
-                }
             }
-        }else
-            // for now just return an empty string.
-            // This is a giant hack but avoids a deadlock
-            this.emit("qmpreturn", '');
+
+            if (msg.QMP !== undefined) {
+                if (this.sentConnected) 
+                    return;
+                    
+                await this.execute({ execute: "qmp_capabilities" });
+
+                this.emit('connected');
+                this.sentConnected = true;
+            }
+            if (msg.return !== undefined)
+                this.emit("qmpreturn", msg.return);
+            else if(msg.event !== undefined) {
+                switch(msg.event) {
+                    case "STOP":
+                    {
+                        log("INFO", "The VM was shut down, restarting...");
+                        this.reboot();
+                        break;
+                    }
+                    case "RESET":
+                    {
+                        log("INFO", "QEMU reset event occured");
+                        this.resume();
+                        break;
+                    };
+                    default: {
+                        this.emit("qmpreturn", "");
+                        break;
+                    }
+                }
+            }else
+                // for now just return an empty string.
+                // This is a giant hack but avoids a deadlock
+                this.emit("qmpreturn", "");
+        }
     }
 
     private onClose() {