Merge pull request #1388 from gkorland/patch-1

Added 'NOACK' to xreadgroup call
redis · Nov 15, 2018 · bd66d62 · bd66d62
2 parents 49a635d + 383f097
commit bd66d62
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);