Skip to content

Commit 6eda556

Browse files
committed
fix: create rabbitmq queues on set config
1 parent 3ea454c commit 6eda556

2 files changed

Lines changed: 2 additions & 4 deletions

File tree

src/libs/amqp.server.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ export const getAMQP = (): amqp.Channel | null => {
4444

4545
export const initQueues = (instanceName: string, events: string[]) => {
4646
console.log('initQueues', instanceName, events);
47-
if (!events.length) return;
47+
if (!events || !events.length) return;
4848

4949
const queues = events.map((event) => {
5050
return `${event.replace(/_/g, '.').toLowerCase()}`;

src/whatsapp/controllers/instance.controller.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -229,16 +229,14 @@ export class InstanceController {
229229
'CHAMA_AI_ACTION',
230230
];
231231
} else {
232-
newEvents = events;
232+
newEvents = rabbitmq_events;
233233
}
234234
this.rabbitmqService.create(instance, {
235235
enabled: true,
236236
events: newEvents,
237237
});
238238

239239
rabbitmqEvents = (await this.rabbitmqService.find(instance)).events;
240-
241-
initQueues(instance.instanceName, rabbitmqEvents);
242240
} catch (error) {
243241
this.logger.log(error);
244242
}

0 commit comments

Comments
 (0)