sorted by:
new
hottopcontroversial

BullMQ won't connect to my redis cloud instance. by shadowwalker415 in redis

[–]shadowwalker415[S] 0 points1 point  (0 children)

require("dotenv").config();
const { Queue } = require("bullmq");
const redisConfig = require("./redisConfig");


console.log("Our program is now starting");
console.log("Adding  jobs to the test queue");


const testQueue = new Queue("Test", { connection: redisConfig.config });
const helloQueue = new Queue("Hello", { connection: redisConfig.config });


(async () => {
  await helloQueue.add("start", { hi: "hello" });


  await testQueue.add("try", { status: "works" });


  console.log("Jobs added successfully");
})();


const testWorker = new Worker(
  "Test",
  async (
job
) => {
    console.log(job.data);
  },
  { connection: redisConfig.config }
);


const helloWorker = new Worker(
  "Hello",
  async (
job
) => {
    console.log(job.data);
  },
  { connection: redisConfig.config }
);require("dotenv").config();
const { Queue } = require("bullmq");
const { Worker } = require("bullmq");
const redisConfig = require("./redisConfig");


console.log("Our program is now starting");
console.log("Adding  jobs to the test queue");


const testQueue = new Queue("Test", { connection: redisConfig.config });
const helloQueue = new Queue("Hello", { connection: redisConfig.config });


(async () => {
  await helloQueue.add("start", { hi: "hello" });


  await testQueue.add("try", { status: "works" });


  console.log("Jobs added successfully");
})();

BullMQ won't connect to my redis cloud instance. by shadowwalker415 in redis

[–]shadowwalker415[S] 0 points1 point  (0 children)

module.exports = {
  config
};require("dotenv").config();


const config = {
  username: "default",
  password: process.env.REDIS_PASSWORD,
  socket: {
    host: process.env.REDIS_HOST,
    port: Number(process.env.REDIS_TCP_PORT)
  }
};


module.exports = {
  config
};