src/adapter/helper/consume.ts
Function consume
has 36 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
export function consume(channel: amqp.Channel, queueName: string, listener: ConsumeHandlerFunction, options: IEventManagerOptions): Promise<IEventPayload | void | null> {
LOGGER.info(`Consume messages of queue ${queueName}`);
return new Promise((resolve, reject) => {
try {
channel.consume(queueName, message => {