I have been researching how to efficiently solve the following use case and I am struggling to find the best solution. Basically I have a Node.js REST API which handles requests for users from a mobile application. We want some…
I am trying to test that after sending a request to one of my controllers, the queue pushes a job. The implementation itself works as expected. This is my app.module.ts @Module({ imports: [ HttpModule, TypeOrmModule.forRoot(typeOrmConfig), BullModule.forRoot({ redis: { host: redisConfig.host,…
I am trying to send DTOs to my Redis queue with a Bull framework and handle these DTOs in processors. Sometimes job pass to processor (1 of 100) but most of the time failed with error: job stalled more than…
I'm using the very basic example (const queue = new Queue('Paint')) from the https://www.npmjs.com/package/bullmq page - everything works fine (it defaults to localhost:6379). However when I add a connection (new Queue('Paint', { connection })) that's based on a TLS access…
I wanted to perform some data processing in parallel using Bull NPM and start processing each job at the given cron Time const Queue = require("bull"), /** * initialize the queue for executing cron jobs **/ this.workQueue = new Queue(this.queueOptions.name,…
When i try to connect my Nodsjs application to RedisCloud on Heroku I am getting the following error Redis::CannotConnectError: Error connecting to Redis on 127.0.0.1:6379 (ECONNREFUSED) I have even tried to directly set the redis URL and port in the…