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);