could you add a new command to run producer?

[scil]

Thank you for your article.

maybe you can add a new command

    "producer": "tsc-watch --onSuccess \"node ./dist/producer.js\" | pino-pretty",

[manast]

Thank you for the suggestion!

[notflip]

@scil What is a good way of doing this? I'm looking for a bullmq example repo that shows how to structure commands to run index and the producer at the same moment. I have not found a good example.

[scil]

there is the index.ts from one of my repo which is used to auto commit any git repo.

import { Worker, QueueScheduler } from "bullmq";
import { commitRepoQueueName ,connection } from "./types";


const commitRepoWorker = new Worker(commitRepoQueueName, `${__dirname}/workers/auto-commit-worker.js`, {
  connection,
});

const commitRepoScheduler = new QueueScheduler(commitRepoQueueName, {
  connection,
});

process.on("SIGTERM", async () => {
  console.info("SIGTERM signal received: closing queues");

  await commitRepoWorker.close();
  await commitRepoScheduler.close();

  console.info("All closed");
});

and the package.json

{
  "name": "bullmq-typescript",
  "version": "1.0.0",
  "description": "to BullMQ to auto commit git repo",
  "license": "MIT",
  "bin": "src/index.ts",
  "scripts": {
    "build": "tsc",
    "worker": "node ./dist/index.js",
    "producer": "node ./dist/producer.js",
    "dev:worker": "tsc-watch --onSuccess \"node ./dist/index.js\" | pino-pretty",
    "dev:producer": "tsc-watch  --onSuccess \"node ./dist/producer.js\" | pino-pretty",
    "test": "ts-mocha ./tests/**/*.test.ts"
  },
  "repository": {
    "type": "git",
    "url": "https://github.com/taskforcesh/bullmq-typescript.git"
  },
  "keywords": [
    "bullmq"
  ],
  "author": "Manuel Astudillo",
  "dependencies": {
    "bullmq": "^1.85.3",
    "consola": "^2.15.3",
    "cronstrue": "^2.11.0",
    "shelljs": "^0.8.5"
  },
  "devDependencies": {
    "@types/node": "^17.0.41",
    "chai": "^4.2.0",
    "mocha": "^6.0.1",
    "node-cmd": "^5.0.0",
    "pino-pretty": "^8.1.0",
    "ts-mocha": "^10.0.0",
    "tsc-watch": "^5.0.3",
    "typescript": "^4.7.3"
  }
}