outgoingEnqueueCombi

aedes.js

@@ -191,9 +191,7 @@ function DoEnqueues () {
       that.complete = null
       that.topic = null
 
-      broker._parallel(
-        status,
-        doEnqueue, subs, complete)
+      broker.persistence.outgoingEnqueueCombi(subs, status.packet, complete)
 
       broker._enqueuers.release(that)
     }
@@ -207,10 +205,6 @@ function removeSharp (sub) {
   return code !== 43 && code !== 35
 }
 
-function doEnqueue (sub, done) {
-  this.broker.persistence.outgoingEnqueue(sub, this.packet, done)
-}
-
 function callPublished (_, done) {
   this.broker.published(this.packet, this.client, done)
   this.broker.emit('publish', this.packet, this.client)

package.json

@@ -48,7 +48,7 @@
   },
   "dependencies": {
     "aedes-packet": "^1.0.0",
-    "aedes-persistence": "^4.0.0",
+    "aedes-persistence": "^5.1.1",
     "bulk-write-stream": "^1.0.0",
     "end-of-stream": "^1.1.0",
     "fastfall": "^1.0.0",