diff --git a/lib/pool.js b/lib/pool.js
index b687af9..f8c5bc2 100644
--- a/lib/pool.js
+++ b/lib/pool.js
@@ -90,6 +90,11 @@ function messageHandler(message) {
                 minerCount[message.data] += 1;
             }
             break;
+        case 'sendRemote':
+            if (cluster.isMaster) {
+                global.database.sendQueue.push(Buffer.from(message.data, 'hex'));
+            }
+            break;
     }
 }
 
diff --git a/lib/remote_comms.js b/lib/remote_comms.js
index d4ec4ee..0dff0dc 100644
--- a/lib/remote_comms.js
+++ b/lib/remote_comms.js
@@ -20,7 +20,7 @@ function Database() {
             function () {
                 callback();
             });
-    }, 32);
+    }, 128);
 
     this.storeShare = function (blockId, shareData) {
         let wsData = global.protos.WSData.encode({
@@ -29,8 +29,7 @@ function Database() {
             msg: shareData,
             exInt: blockId
         });
-        this.sendQueue.push({body: wsData}, function () {
-        });
+        process.send({type: 'sendRemote', body: wsData.toString('hex')});
     };
 
     this.storeBlock = function (blockId, blockData) {
@@ -40,8 +39,7 @@ function Database() {
             msg: blockData,
             exInt: blockId
         });
-        this.sendQueue.push({body: wsData}, function () {
-        });
+        process.send({type: 'sendRemote', body: wsData.toString('hex')});
     };
 
     this.storeInvalidShare = function (minerData) {
@@ -51,8 +49,7 @@ function Database() {
             msg: minerData,
             exInt: 1
         });
-        this.sendQueue.push({body: wsData}, function () {
-        });
+        process.send({type: 'sendRemote', body: wsData.toString('hex')});
     };
 
     this.initEnv = function(){