Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
async shouldNackAndRequeueTimes3(
message: object,
raw: amqplib.ConsumeMessage,
) {
++this.nackCount;
nackAndRequeueHandler();
// await sleep(15);
if (this.nackCount >= 3) {
return new Nack();
}
return new Nack(true);
}
}
async shouldNackAndRequeueTimes3(
message: object,
raw: amqplib.ConsumeMessage,
) {
++this.nackCount;
nackAndRequeueHandler();
// await sleep(15);
if (this.nackCount >= 3) {
return new Nack();
}
return new Nack(true);
}
}
shouldNack(message: object, raw: amqplib.ConsumeMessage) {
nackHandler();
return new Nack();
}