Searched refs:consumername (Results 1 – 1 of 1) sorted by relevance
1340 robj *consumername = NULL; in xreadCommand() local1373 consumername = c->argv[i+2]; in xreadCommand()1521 consumername->ptr,1); in xreadCommand()1560 incrRefCount(consumername); in xreadCommand()1562 c->bpop.xread_consumer = consumername; in xreadCommand()1927 robj *consumername = (c->argc == 7) ? c->argv[6] : NULL; in xpendingCommand() local2008 streamConsumer *consumer = consumername ? in xpendingCommand()2009 streamLookupConsumer(group,consumername->ptr,0): in xpendingCommand()2014 if (consumername && consumer == NULL) { in xpendingCommand()