Registry / messaging / queue-port

queue-port

JSON →
library0.0.6jsnpmunverified

Queue-Port is an HTTP-based queue server library for Node.js (v0.0.6, latest) implementing a basic FIFO queue based on the Actor Model. It allows enqueuing and dequeuing items by named queues via REST API, with support for blocking dequeue with configurable timeouts (indefinite, immediate, or milliseconds). Key differentiators include a built-in optional dashboard server for monitoring queues/waiters and a simple HTTP interface without external dependencies. Written in TypeScript with type definitions. Currently in early development with limited features compared to mature solutions like Bull or Bee-Queue.

messaging
npm install queue-port
github ↗package ↗homepage ↗
INSTALL
IMPORT
SIG · QUEUE-PORT
Q
queue-port
messagingjavascriptv0.0.6
harness data pending
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.

start
✓ import * as queuePort from 'queue-port'; queuePort.start()
✗ import { start } from 'queue-port'
ESM-only; named export 'start' is not a default export. Use namespace import or 'const queuePort = require('queue-port')' for CommonJS.
Queue
✓ import * as queuePort from 'queue-port'; const q = queuePort.Queue
✗ import { Queue } from 'queue-port'
No direct Queue export; internal class not exposed.
default import
✓ import queuePort from 'queue-port'
No default export; use namespace import instead.

Starts the Queue-Port HTTP server with default settings, enabling enqueue/dequeue operations via REST API.

// server.mjs import * as queuePort from 'queue-port'; queuePort.start({ port: 8765, enableDashboardServer: false }).then(() => { console.log('Queue-Port running on port 8765'); }).catch((err) => { console.error('Failed to start:', err); });
Debug
Known issues
gotchaThe 'start' function returns a Promise; failing to await or .catch() may cause unhandled promise rejections.
fix
Always handle the returned promise with .then()/.catch() or surround with async/await and try/catch.
affects: >=0.0.1
gotchaDequeue with timeout -1 (default) blocks indefinitely, potentially causing memory leaks or hanging requests if no items arrive.
fix
Set a positive timeout or 0 to avoid indefinite blocking, or ensure clients will eventually provide items.
affects: >=0.0.1
gotchaNo authentication or authorization mechanisms; any HTTP client can access all endpoints.
fix
Run behind a reverse proxy with authentication or add middleware manually.
affects: >=0.0.1
deprecatedPackage is in early development (v0.0.6); API may change without notice.
fix
Pin exact version in package.json and monitor releases for breaking changes.
affects: >=0.0.1
Errors
Common errors & fixes
Error: listen EADDRINUSE :::8765
Port 8765 is already in use.
fix
Stop the other process using the port, or specify a different port in the options.
TypeError: Cannot read properties of undefined (reading 'port')
Calling start() with an undefined or null options object when accessing nested properties.
fix
Pass an empty object or undefined: queuePort.start() or queuePort.start({}).
Error [ERR_REQUIRE_ESM]: require() of ES Module
Attempting to use require() to import the package in a CommonJS module.
fix
Use dynamic import: const queuePort = await import('queue-port'); or set type: module in package.json.
Upgrade
Version history
0.0.6latest on npm
Audit
Dependencies

No dependency data recorded yet.

Agent activity
19 hits · last 30 days
node
16
Amazon
1
OpenAI (training)
1
Resources
githubhttps://github.com/moztemur/queue-port ↗
packagequeue-port ↗
homepagehttps://github.com/moztemur/queue-port ↗
queue-port — npm install queue-port · libregistry