fix: create rabbitmq queues on set config

This commit is contained in:
Davidson Gomes 2023-08-31 17:01:09 -03:00
parent 9123d7014d
commit 3ea454c7ed

View File

@ -43,6 +43,9 @@ export const getAMQP = (): amqp.Channel | null => {
};
export const initQueues = (instanceName: string, events: string[]) => {
console.log('initQueues', instanceName, events);
if (!events.length) return;
const queues = events.map((event) => {
return `${event.replace(/_/g, '.').toLowerCase()}`;
});