Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
QueueService
✓ const { QueueService } = require('engined-queue')
✗ import { QueueService } from 'engined-queue'
Package is CommonJS-only; no ESM exports.
Consumer
✓ const { Consumer } = require('engined-queue')
✗ const Consumer = require('engined-queue').Consumer
Named export; default import is not available.
engined-queue
✓ const enginedQueue = require('engined-queue')
✗ import enginedQueue from 'engined-queue'
CommonJS require() is the only supported import style.
Sets up an engined manager with AMQP service, queue service, and a consumer, then starts all services.
const { Manager } = require('engined');
const AMQPService = require('engined-amqp');
const { QueueService, Consumer } = require('engined-queue');
const main = async () => {
const manager = new Manager({ verbose: true });
manager.add('AMQP', AMQPService);
manager.add('Queue', QueueService({ uri: process.env.AMQP_URI ?? 'amqp://localhost/myvhost' }));
const MyConsumer = class extends Consumer({
exchangeName: 'myexchange',
exchangeType: 'topic',
targetQueue: 'myqueue',
routingRules: 'black.*'
}) {
consume(routingKey, msg) {
console.log('Received:', routingKey, msg);
return true;
}
};
manager.add('MyConsumer', MyConsumer);
await manager.startAll();
};
main().catch(console.error);
Errors
Common errors & fixes
Cannot find module 'engined-amqp'
engined-amqp is a peer dependency and must be installed separately.
fixRun: npm install engined-amqp
Consumer is not a constructor
Consumer is a function that returns a class, not a class itself.
fixUse: class MyConsumer extends Consumer({...}) { ... } or const MyConsumer = class extends Consumer({...}) { ... }; Cannot read property 'URI' of undefined
The QueueService expects a URI option but received undefined.
fixPass a valid URI: QueueService({ uri: 'amqp://localhost/myvhost' }) Audit
Dependencies
engined-amqprequiredThis package is built on engined-amqp and requires it at runtime.