New Research: Supply Chain Attack on Axios Pulls Malicious Dependency from npm.Details →
Socket
Book a DemoSign in
Socket
Book a DemoSign in

@mqueue/null

Package Overview
Dependencies
Maintainers
1
Versions
12
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@mqueue/null - npm Package Compare versions

Comparing version
1.0.0-next-20250728071929
 to
1.0.0
+5
-9
package.json
{
"name": "@mqueue/null",
"version": "1.0.0-next-20250728071929",
"version": "1.0.0",
"type": "module",

@@ -11,3 +11,3 @@ "description": "Dead-end/testing MQueue adapter",

"engines": {
"node": ">=18"
"node": ">=20"
},

@@ -22,6 +22,2 @@ "files": [

"default": "./dist/index.js"
},
"require": {
"types": "./dist/index.d.cts",
"default": "./dist/index.cjs"
}

@@ -41,3 +37,3 @@ }

"peerDependencies": {
"@mqueue/queue": "0.1.0-next-20250728071929"
"@mqueue/queue": "1.0.0"
},

@@ -50,6 +46,6 @@ "devDependencies": {

"typescript": "^5.8.3",
"@mqueue/queue": "0.1.0-next-20250728071929"
"@mqueue/queue": "1.0.0"
},
"scripts": {
"build": "tsup src/index.ts --no-config --dts --format esm,cjs --cjsInterop --minify --sourcemap --splitting --treeshake",
"build": "tsup src/index.ts --no-config --dts --format esm --cjsInterop --minify --sourcemap --splitting --treeshake",
"typecheck": "tsc --noEmit",

@@ -56,0 +52,0 @@ "test": "node --import tsx --test --test-reporter=spec tests/**/*.test.ts tests/*.test.ts",

+12
-0
README.md

@@ -13,2 +13,5 @@ # Dead-end (Null) Adapter for MQueue

```ts
import MQueue from "@mqueue/queue"; // or require("@mqueue/queue");
import { NullQueue } from "@mqueue/null"; // or require("@mqueue/null");
const outgoingQueue = new MQueue.Outgoing(new NullQueue.Outgoing());

@@ -26,2 +29,11 @@

const incomingQueue = new MQueue.Incoming(new NullQueue.Incoming());
// Start listening to the queue
await incomingQueue.consume(async (payload) => {
const topicOrQueueName = payload.transport.name;
const headers = payload.message.headers;
const data = await payload.message.json();
await payload.accept(); // or await payload.reject();
// ...
});
```
-2
dist/index.cjs
'use strict';var e=class{type="null";constructor(){}async healthcheck(){}async close(){}async consume(){}};var o=class{type="null";constructor(){}async healthcheck(){}async close(){}async sendMessage(){}};var t=class{constructor(){}static Outgoing=o;static Incoming=e};exports.NullIncomingQueue=e;exports.NullOutgoingQueue=o;exports.NullQueue=t;//# sourceMappingURL=index.cjs.map
//# sourceMappingURL=index.cjs.map
-1
dist/index.cjs.map
{"version":3,"sources":["../src/NullIncomingQueue.ts","../src/NullOutgoingQueue.ts","../src/NullQueue.ts"],"names":["NullIncomingQueue","NullOutgoingQueue","NullQueue"],"mappings":"aAEqBA,IAAAA,CAAAA,CAArB,KAAuE,CAC9D,IAAO,CAAA,MAAA,CACd,aAAc,EACd,MAAa,WAAA,EAA6B,EAC1C,MAAa,KAAuB,EAAA,EACpC,MAAa,OAAyB,EAAA,EACxC,ECNqBC,IAAAA,CAAAA,CAArB,KAAuE,CAC9D,IAAO,CAAA,MAAA,CAEd,aAAc,EACd,MAAa,WAAA,EAA6B,EAC1C,MAAa,KAAA,EAAuB,EACpC,MAAa,WAAA,EAA6B,EAC5C,ECNqBC,IAAAA,CAAAA,CAArB,KAA+B,CACrB,WAAc,EAAA,EAEtB,OAAc,QAAWD,CAAAA,CAAAA,CACzB,OAAc,QAAA,CAAWD,CAC3B","file":"index.cjs","sourcesContent":["import { IncomingQueueAdapter } from \"@mqueue/queue\";\n\nexport default class NullIncomingQueue implements IncomingQueueAdapter {\n public type = \"null\";\n constructor() {}\n public async healthcheck(): Promise<void> {}\n public async close(): Promise<void> {}\n public async consume(): Promise<void> {}\n}\n","import { OutgoingQueueAdapter } from \"@mqueue/queue\";\n\nexport default class NullOutgoingQueue implements OutgoingQueueAdapter {\n public type = \"null\";\n\n constructor() {}\n public async healthcheck(): Promise<void> {}\n public async close(): Promise<void> {}\n public async sendMessage(): Promise<void> {}\n}\n","import NullIncomingQueue from \"./NullIncomingQueue.js\";\nimport NullOutgoingQueue from \"./NullOutgoingQueue.js\";\n\nexport default class NullQueue {\n private constructor() {}\n\n public static Outgoing = NullOutgoingQueue;\n public static Incoming = NullIncomingQueue;\n}\n"]}
-25
dist/index.d.cts
import { IncomingQueueAdapter, OutgoingQueueAdapter } from '@mqueue/queue';
declare class NullIncomingQueue implements IncomingQueueAdapter {
type: string;
constructor();
healthcheck(): Promise<void>;
close(): Promise<void>;
consume(): Promise<void>;
}
declare class NullOutgoingQueue implements OutgoingQueueAdapter {
type: string;
constructor();
healthcheck(): Promise<void>;
close(): Promise<void>;
sendMessage(): Promise<void>;
}
declare class NullQueue {
private constructor();
static Outgoing: typeof NullOutgoingQueue;
static Incoming: typeof NullIncomingQueue;
}
export { NullIncomingQueue, NullOutgoingQueue, NullQueue };