diff --git a/abstract.js b/abstract.js
index f8dc606..164774a 100644
--- a/abstract.js
+++ b/abstract.js
@@ -906,11 +906,12 @@ function abstractPersistence (opts) {
     }
     var queue = []
     enqueueAndUpdate(t, instance, client, sub, packet1, 42, function (updated1) {
-      enqueueAndUpdate(t, instance, client, sub, packet2, 42, function (updated2) {
+      enqueueAndUpdate(t, instance, client, sub, packet2, 43, function (updated2) {
         var stream = instance.outgoingStream(client)
         pump(stream, through.obj(function clearQueue (data, enc, next) {
           instance.outgoingUpdate(client, data,
-            function (_, client, packet) {
+            function (err, client, packet) {
+              t.notOk(err, 'no error')
               queue.push(packet)
               next()
             })
diff --git a/package.json b/package.json
index 25ebdad..b0a1bd6 100644
--- a/package.json
+++ b/package.json
@@ -71,7 +71,7 @@
     "through2": "^3.0.1"
   },
   "dependencies": {
-    "aedes-packet": "^2.1.0",
+    "aedes-packet": "^2.3.1",
     "from2": "^2.3.0",
     "qlobber": "^5.0.0"
   }
diff --git a/persistence.js b/persistence.js
index b239691..6b8813d 100644
--- a/persistence.js
+++ b/persistence.js
@@ -355,3 +355,4 @@ MemoryPersistence.prototype.destroy = function (cb) {
 }
 
 module.exports = MemoryPersistence
+module.exports.Packet = Packet