Merge pull request #152 from behrad/outgotingEnqueueCombi

outgoingEnqueueCombi
moscajs · Aug 19, 2017 · 663707a · 663707a
2 parents 4560c1f + fae7d80
commit 663707a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 8 deletions.
diff --git a/aedes.js b/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)

diff --git a/package.json b/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",