diff options
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index 069d3ba95..5d6d0c800 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -489,7 +489,7 @@ void serveClientsBlockedOnStreamKey(robj *o, readyList *rl) { if (group) { noack = receiver->bpop.xread_group_noack; sds name = receiver->bpop.xread_consumer->ptr; - consumer = streamLookupConsumer(group,name,SLC_DEFAULT); + consumer = streamLookupConsumer(group,name); if (consumer == NULL) { consumer = streamCreateConsumer(group,name,rl->key, rl->db->id,SCC_DEFAULT); |