Skip to content

Commit bd66d62

Browse files
authored
Merge pull request #1388 from gkorland/patch-1
Added 'NOACK' to xreadgroup call
2 parents 49a635d + 383f097 commit bd66d62

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

examples/streams.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,15 +15,15 @@ client1.xadd('mystream', '*', 'field1', 'm1', function (err) {
1515
}
1616
});
1717

18-
client2.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000,
18+
client2.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 'NOACK',
1919
'STREAMS', 'mystream', '>', function (err, stream) {
2020
if(err){
2121
return console.error(err);
2222
}
2323
console.log('client2 ' + stream);
2424
});
2525

26-
client3.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000,
26+
client3.xreadgroup('GROUP', 'mygroup', 'consumer', 'Block', 1000, 'NOACK',
2727
'STREAMS', 'mystream', '>', function (err, stream) {
2828
if(err){
2929
return console.error(err);

0 commit comments

Comments
 (0)