We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b04c9ab commit 432ad5aCopy full SHA for 432ad5a
src/query/queues.ts
@@ -14,9 +14,15 @@ export function createQueuesFC(
14
type: 'String',
15
defaultValue: 'bull',
16
},
17
+ names: {
18
+ type: '[String!]',
19
+ },
20
- resolve: async (_, { prefix }) => {
- const titles = await scanQueueTitles(prefix, opts);
21
+ resolve: async (_, { prefix, names }) => {
22
+ //Если передали имена, значит они согласованы с префиксом (bull.[имя проекта]).
23
+ const titles = names
24
+ ? names.map((name: string) => ({ prefix, queueName: name }))
25
+ : await scanQueueTitles(prefix, opts);
26
return getQueues(titles, opts);
27
28
};
0 commit comments