chore!: update @boringnode/queue package

Author: RomainLanz

commands/queue_work.ts

@@ -10,7 +10,7 @@
 import { flags, BaseCommand } from '@adonisjs/core/ace'
 import { resolveAdapters, resolveJobFactory } from '../src/utils.js'
 import type { CommandOptions } from '@adonisjs/core/types/ace'
-import type { QueueConfig } from '../src/types/main.js'
+import type { QueueConfig, QueueManagerConfig } from '../src/types/main.js'
 
 export default class QueueWork extends BaseCommand {
   static commandName = 'queue:work'
@@ -30,6 +30,8 @@ export default class QueueWork extends BaseCommand {
   async run() {
     const { Worker } = await import('@boringnode/queue')
     const config = this.app.config.get<QueueConfig>('queue')
+    const queueManager = await this.app.container.make('queue.manager')
+    const logger = await this.app.container.make('logger')
 
     /**
      * Commit the router to ensure all routes are registered.
@@ -45,12 +47,23 @@ export default class QueueWork extends BaseCommand {
     this.logger.info(`Starting worker for queues: ${queues.join(', ')}`)
     const jobFactory = resolveJobFactory(config, this.app)
 
-    const worker = new Worker({
+    const workerConfig = {
       ...config,
       adapters: resolvedAdapters,
       jobFactory,
-      ...(this.concurrency && { concurrency: this.concurrency }),
-    })
-    await worker.start(queues)
+      logger: config.logger ?? logger,
+      worker: {
+        ...config.worker,
+        ...(this.concurrency !== undefined ? { concurrency: this.concurrency } : {}),
+      },
+    } satisfies QueueManagerConfig
+
+    const worker = new Worker(workerConfig)
+
+    try {
+      await worker.start(queues)
+    } finally {
+      await queueManager.destroy()
+    }
   }
 }

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@adonisjs/queue",
   "description": "Queue system for AdonisJS powered by @boringnode/queue",
-  "version": "0.4.2",
+  "version": "0.5.0",
   "engines": {
     "node": ">=24.0.0"
   },
@@ -35,7 +35,7 @@
     "version": "npm run build"
   },
   "dependencies": {
-    "@boringnode/queue": "^0.4.0",
+    "@boringnode/queue": "^0.5.0",
     "@poppinss/utils": "^7.0.1"
   },
   "devDependencies": {