diff --git a/lib/pool.js b/lib/pool.js
index 0817c6b..82195f4 100644
--- a/lib/pool.js
+++ b/lib/pool.js
@@ -103,7 +103,7 @@ function messageHandler(message) {
             break;
         case 'sendRemote':
             if (cluster.isMaster) {
-                global.database.sendQueue.push(Buffer.from(message.data, 'hex'));
+                global.database.sendQueue.push({body: Buffer.from(message.body, 'hex')});
             }
             break;
         case 'trustedShare':
diff --git a/lib/remote_comms.js b/lib/remote_comms.js
index 3c9a69a..a91baaa 100644
--- a/lib/remote_comms.js
+++ b/lib/remote_comms.js
@@ -22,7 +22,7 @@ function Database() {
             function () {
                 callback();
             });
-    }, 128);
+    }, require('os').cpus().length*32);
 
     this.storeShare = function (blockId, shareData) {
         let wsData = global.protos.WSData.encode({
@@ -55,7 +55,7 @@ function Database() {
     };
 
     setInterval(function(queue_obj){
-        if (thread_id === '(Master) '){
+        if (global.database.thread_id === '(Master) '){
             console.log(global.database.thread_id + "Queue debug state: " + queue_obj.length() + " items in the queue " + queue_obj.running() + " items being processed");
         }
     }, 5000, this.sendQueue);