Added 'NOACK' to xreadgroup call

Added 'NOACK' to xreadgroup call, to make sure entries are auto ACK
redis · Nov 14, 2018 · 383f097 · 383f097
1 parent 49a635d
commit 383f097
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/streams.js b/examples/streams.js
@@ -15,15 +15,15 @@ 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);	
 		}
 	    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);