From 383f09702981fe55fed914af8d725084fb2ce0fe Mon Sep 17 00:00:00 2001 From: Guy Korland Date: Wed, 14 Nov 2018 04:51:56 +0200 Subject: [PATCH] Added 'NOACK' to xreadgroup call Added 'NOACK' to xreadgroup call, to make sure entries are auto ACK --- examples/streams.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/streams.js b/examples/streams.js index 1aeeca0a081..2fda1293ce4 100644 --- a/examples/streams.js +++ b/examples/streams.js @@ -15,7 +15,7 @@ client1.xadd('mystream', '*', 'field1', 'm1', function (err) { } }); - client2.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, + client2.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 'NOACK', 'STREAMS', 'mystream', '>', function (err, stream) { if(err){ return console.error(err); @@ -23,7 +23,7 @@ client1.xadd('mystream', '*', 'field1', 'm1', function (err) { console.log('client2 ' + stream); }); - client3.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, + client3.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 'NOACK', 'STREAMS', 'mystream', '>', function (err, stream) { if(err){ return console.error(err);