Skip to content
GitLab
Projects Groups Snippets
  • /
  • Help
    • Help
    • Support
    • Community forum
    • Submit feedback
    • Contribute to GitLab
  • Sign in / Register
  • B bull
  • Project information
    • Project information
    • Activity
    • Labels
    • Members
  • Repository
    • Repository
    • Files
    • Commits
    • Branches
    • Tags
    • Contributors
    • Graph
    • Compare
  • Issues 175
    • Issues 175
    • List
    • Boards
    • Service Desk
    • Milestones
  • Merge requests 9
    • Merge requests 9
  • CI/CD
    • CI/CD
    • Pipelines
    • Jobs
    • Schedules
  • Deployments
    • Deployments
    • Environments
    • Releases
  • Packages and registries
    • Packages and registries
    • Package Registry
    • Infrastructure Registry
  • Monitor
    • Monitor
    • Incidents
  • Analytics
    • Analytics
    • Value stream
    • CI/CD
    • Repository
  • Wiki
    • Wiki
  • Snippets
    • Snippets
  • Activity
  • Graph
  • Create a new issue
  • Jobs
  • Commits
  • Issue Boards
Collapse sidebar
  • OptimalBits
  • bull
  • Issues
  • #845
Closed
Open
Issue created Jan 18, 2018 by Administrator@rootContributor

When call queue.close() bull throws Error: Connection is closed.

Created by: mseld

Description

Handling Graceful Shutdown Bull throws Error after call queue.close()

Test code to reproduce

// just Press CTRL+C after 1 min while component processing messages
const Queue = require('bull');

let queue = ('mail-queue', 'redis://127.0.0.1:6379');

queue.process(function (job, done) {
     // code ...
});

process.on('SIGINT', function () {
    setTimeout(() => {
        queue.close();
    }, 3000);
});

process.on('SIGTERM', function onSigterm() {
    setTimeout(() => {
        queue.close();
    }, 3000);
});

Bull version

3.3.7&8

Additional information

Error: Connection is closed. at Redis.sendCommand (/folders/exe/hlr_charging/node_modules/ioredis/lib/redis.js:558:20) at Redis.zrevrange (/folders/exe/hlr_charging/node_modules/ioredis/lib/commander.js:131:17) at /folders/exe/hlr_charging/node_modules/bull/lib/getters.js:135:76 at /folders/exe/hlr_charging/node_modules/bull/lib/getters.js:26:18 at arrayMap (/folders/exe/hlr_charging/node_modules/lodash/lodash.js:660:23) at Function.map (/folders/exe/hlr_charging/node_modules/lodash/lodash.js:9571:14) at Queue._commandByType (/folders/exe/hlr_charging/node_modules/bull/lib/getters.js:16:14) at Queue.getRanges (/folders/exe/hlr_charging/node_modules/bull/lib/getters.js:124:30) at Queue.getJobs (/folders/exe/hlr_charging/node_modules/bull/lib/getters.js:146:17) at Queue.getFailed (/folders/exe/hlr_charging/node_modules/bull/lib/getters.js:115:17) at Timeout._onTimeout (/folders/exe/hlr_charging/index.js:83:11) at ontimeout (timers.js:386:11) at tryOnTimeout (timers.js:250:5) at Timer.listOnTimeout (timers.js:214:5)

Assignee
Assign to
Time tracking