diff --git a/cluster.js b/cluster.js
index bc3ee8ec118..a64fbb7b08a 100644
--- a/cluster.js
+++ b/cluster.js
@@ -19,9 +19,6 @@ function cluster () {
     return
   }
 
-  let dbData = []
-  setInterval(() => sendDBDataUntilAck(), 10)
-
   global.configuration = new (require('./libs/configuration.js'))()
   global.currency = new (require('./libs/currency.js'))()
   global.users = new (require('./libs/users.js'))()
@@ -54,11 +51,8 @@ function cluster () {
           await message(data)
           workerIsFree.message = true
           break
-        case 'dbAck':
-          debug('cluster:dbAck')(data)
-          dbData = _.filter(dbData, (o) => o.id !== data.id)
-          break
         case 'db':
+          workerIsFree.db = false
           switch (data.fnc) {
             case 'find':
               data.items = await global.db.engine.find(data.table, data.where)
@@ -84,20 +78,12 @@ function cluster () {
             default:
               global.log.error('This db call is not correct\n%j', data)
           }
-          dbData.push(data)
+          process.send(data)
+          workerIsFree.db = true
       }
     })
   })
 
-  function sendDBDataUntilAck () {
-    debug('cluster:sendDBDataUntilAck:data')(dbData.length)
-    for (let data of dbData) {
-      debug('cluster:sendDBDataUntilAck')(data)
-      process.send(data)
-    }
-    workerIsFree.db = dbData.length === 0
-  }
-
   async function message (data) {
     let sender = data.sender
     let message = data.message
diff --git a/libs/databases/master.js b/libs/databases/master.js
index b617623d5c0..c30ee284943 100644
--- a/libs/databases/master.js
+++ b/libs/databases/master.js
@@ -12,7 +12,6 @@ class IMasterController extends Interface {
 
     cluster.on('message', (worker, message) => {
       debug('db:master:incoming')(`Got data from Worker#${worker.id}\n${util.inspect(message)}`)
-      worker.send({ type: 'dbAck', id: message.id })
       this.data[message.id] = {
         items: message.items,
         timestamp: _.now(),