Closed
Description
Looks like the flows prefix is not working correctly.
const bullQueueOptions: BullQueueOptions = {
prefix: this.config.prefix, // set to something besides `bull`
connection: this.redisManager.getConnection(this.config.redisConnection),
};
this.flowProducer = new FlowProducer(bullQueueOptions || {}).on("error", (error) => {
if (!error.message.includes("ECONNRESET")) {
logger.error("flow producer error", error.message);
}
});
Activity