diff --git a/test/messaging.test.js b/test/messaging.test.js
index e1584f3..bb12f0d 100644
--- a/test/messaging.test.js
+++ b/test/messaging.test.js
@@ -39,7 +39,8 @@ describe('cap/samples - Messaging', ()=>{
   ]))
 
   it ('should have received all messages', async()=> {
-    await new Promise((done)=>setImmediate(done))
+    // wait for task queue processor to finish
+    await new Promise((done)=>setTimeout(done, 700))
     expect(count).equals(received.length).equals(5)
     expect(received.map(m=>m.data)).to.deep.equal([
       { subject: '201', reviews: 1, rating: 1.0 },