diff --git a/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts b/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts index 87c82b34f2..a2c5899977 100644 --- a/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts +++ b/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts @@ -13,17 +13,19 @@ describe('XINFO CONSUMERS', () => { it('transformReply', () => { assert.deepEqual( transformReply([ - ['name', 'Alice', 'pending', 1, 'idle', 9104628], - ['name', 'Bob', 'pending', 1, 'idle', 83841983] + ['name', 'Alice', 'pending', 1, 'idle', 9104628, 'inactive', 9281221], + ['name', 'Bob', 'pending', 1, 'idle', 83841983, 'inactive', 7213871] ]), [{ name: 'Alice', pending: 1, - idle: 9104628 + idle: 9104628, + inactive: 9281221, }, { name: 'Bob', pending: 1, - idle: 83841983 + idle: 83841983, + inactive: 7213871, }] ); }); diff --git a/packages/client/lib/commands/XINFO_CONSUMERS.ts b/packages/client/lib/commands/XINFO_CONSUMERS.ts index 05e3a26b17..9b3893cc93 100644 --- a/packages/client/lib/commands/XINFO_CONSUMERS.ts +++ b/packages/client/lib/commands/XINFO_CONSUMERS.ts @@ -15,12 +15,14 @@ type XInfoConsumersReply = Array<{ name: RedisCommandArgument; pending: number; idle: number; + inactive: number; }>; export function transformReply(rawReply: Array): XInfoConsumersReply { return rawReply.map(consumer => ({ name: consumer[1], pending: consumer[3], - idle: consumer[5] + idle: consumer[5], + inactive: consumer[7] })); }