{"_id":"@anyq/azure-servicebus","_rev":"7-4cc4d0da8b2174ab259345ddc5661e09","name":"@anyq/azure-servicebus","dist-tags":{"latest":"0.5.0"},"versions":{"0.1.0":{"name":"@anyq/azure-servicebus","version":"0.1.0","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":{"name":"Shantanu Sharma"},"license":"MIT","_id":"@anyq/azure-servicebus@0.1.0","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"7c935dab4f210cd35bc6fa0420ee4821f602e800","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.1.0.tgz","fileCount":17,"integrity":"sha512-MO1FUJE192/sX9f9aDqR1n0NJ/DZXY9EqchoAGTY4s5l4AAD5Y2lClzHSwn3cY3KmYj6XICCNl+TYhj+GUn2rg==","signatures":[{"sig":"MEUCIFQpRHWKPH2Z2MCQb68ehphHpO/OQGxXOecQJwrJUctiAiEA1idrgXxZgz9qdi9GHCuT4pw6T47/s/a2i911/wOPQ0s=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":44338},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"gitHead":"1210b51fe4a55144ebf5bc798db0732b4c89ddba","scripts":{"dev":"tsc --watch","build":"tsc","clean":"rm -rf dist","typecheck":"tsc --noEmit"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"repository":{"url":"git+https://github.com/sns45/anyq.git","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.9.2","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"22.17.0","dependencies":{"@anyq/core":"workspace:*","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"workspace:*"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.1.0_1765990979006_0.24691710167687542","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@anyq/azure-servicebus","version":"0.1.1","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":{"name":"Shantanu Sharma"},"license":"MIT","_id":"@anyq/azure-servicebus@0.1.1","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"159392fd1149e72019d8196f63c729b02c875572","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.1.1.tgz","fileCount":18,"integrity":"sha512-Vy76FJfrX9ItgzRv2CUqq+cjA09niwV8knuMnO+rHJijEVdvtOviDAEWluKqyUDAsGQG3ls7zGzLPfS85YThCw==","signatures":[{"sig":"MEUCIQCWvP0tFRICg7l272pEQRFWejmKu/38WPPNJXfmDVkeYgIgY9UavkmBho7bzWNCdUpjnC3YcEIiL80spsP+Vn12qJI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":46269},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"gitHead":"30128d564178a5a1d25b736b605bf69644178a0f","scripts":{"dev":"tsc --watch","build":"tsc","clean":"rm -rf dist","typecheck":"tsc --noEmit"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"repository":{"url":"git+https://github.com/sns45/anyq.git","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.9.2","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"22.17.0","dependencies":{"@anyq/core":"workspace:*","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"workspace:*"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.1.1_1765991389711_0.6519458668713543","host":"s3://npm-registry-packages-npm-production"}},"0.3.0":{"name":"@anyq/azure-servicebus","version":"0.3.0","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/azure-servicebus@0.3.0","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"aae852d04a96bdaf7d2e1c4c3cb06c51f8947a5e","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.3.0.tgz","fileCount":18,"integrity":"sha512-r0URvYIWpgnIwjk77XGfMd1ANoQ5IiBFVIoMvKjZsyrehFbt4+MvXOllSnZhu8sMEdVMGu0AJ7t5CvxmGGMi1Q==","signatures":[{"sig":"MEQCIAYZeeKqwXE3VFPWRnaU2AbmZHEtjuvYi0tw/v6jc96QAiAetUYlBY2BQOOrbTOQAnyrcBlN13g8dFYTkKvKW4nEMw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":49090},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"aae852d04a96bdaf7d2e1c4c3cb06c51f8947a5e","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"scripts":{"dev":"bun build ./src/index.ts --outdir ./dist --target bun --watch","build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --build --force"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-r0URvYIWpgnIwjk77XGfMd1ANoQ5IiBFVIoMvKjZsyrehFbt4+MvXOllSnZhu8sMEdVMGu0AJ7t5CvxmGGMi1Q==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.8.3","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.0","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"0.3.0"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.3.0_1781961983068_0.09731072205085001","host":"s3://npm-registry-packages-npm-production"}},"0.3.1":{"name":"@anyq/azure-servicebus","version":"0.3.1","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/azure-servicebus@0.3.1","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"9ef690e6b553013a00cabf66deede21f532e81bc","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.3.1.tgz","fileCount":18,"integrity":"sha512-jgdyRZYkMXdsEyBSUPV3Hf1qNjH8UcdjnfMhJ2UBarSsiEeoO21Xvj7F3/JWR8IP+LGdA5cbv1OCWpgq3qMiUw==","signatures":[{"sig":"MEYCIQCFca4lnIpnE+y0vlMA1+7rjcPk4XHb1Idr1Q+0hq3d3QIhAIM7OPaha6cciw9L6RWXmUk5oe9+saZ/0Q7jnHKYtKyI","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":56150},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"9ef690e6b553013a00cabf66deede21f532e81bc","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"scripts":{"dev":"bun build ./src/index.ts --outdir ./dist --target bun --watch","build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --build --force"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-jgdyRZYkMXdsEyBSUPV3Hf1qNjH8UcdjnfMhJ2UBarSsiEeoO21Xvj7F3/JWR8IP+LGdA5cbv1OCWpgq3qMiUw==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.8.3","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.0","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"0.3.0"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.3.1_1782054606160_0.30468360648504866","host":"s3://npm-registry-packages-npm-production"}},"0.3.2":{"name":"@anyq/azure-servicebus","version":"0.3.2","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/azure-servicebus@0.3.2","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"600b173e8cbeae07ccb93985c6050835ed59080a","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.3.2.tgz","fileCount":18,"integrity":"sha512-jOC2fcOwZisKxVj1kTzrRBi8i5w1lVddV/gFYlTyQ0IW1Jk2iTPxPlyBYpPjzsbpOCOIAdjgfhL58jMRdbvgVA==","signatures":[{"sig":"MEQCIA+qnGFrE+E0WynNl49l/FZmUNZCOKp/njDrHEvHiUeSAiAxgIMjRkSyJDE+diEeVwyh70+/TOwkPcoU++gN9KAszw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":56150},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"600b173e8cbeae07ccb93985c6050835ed59080a","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"scripts":{"dev":"bun build ./src/index.ts --outdir ./dist --target bun --watch","build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --build --force"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-jOC2fcOwZisKxVj1kTzrRBi8i5w1lVddV/gFYlTyQ0IW1Jk2iTPxPlyBYpPjzsbpOCOIAdjgfhL58jMRdbvgVA==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.8.3","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.2","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"0.3.2"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.3.2_1784910276114_0.110789944672117","host":"s3://npm-registry-packages-npm-production"}},"0.4.0":{"name":"@anyq/azure-servicebus","version":"0.4.0","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"author":"Shantanu Sharma","license":"Apache-2.0","_id":"@anyq/azure-servicebus@0.4.0","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"dist":{"shasum":"150e586463a47b55e2521c43954eece627bc3b8b","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.4.0.tgz","fileCount":20,"integrity":"sha512-pp4cJOrjcivi2JpfbWHJWOr+F0XL/wIZrJOw9Bc8Q9vUOuGwqp5MAsZqzWhJl/VbTq+USLOH8K5kfUC8PW07lQ==","signatures":[{"sig":"MEUCIAj6CtZsaPOsvYUtOHFLMvffA0Q3sUnG+3S3tpowpa3HAiEAh+L0EJaNLno5r+t/2a+DKcLa4YtKpKQWHbWD8rKHyBM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":68168},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"150e586463a47b55e2521c43954eece627bc3b8b","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"scripts":{"dev":"bun build ./src/index.ts --outdir ./dist --target bun --watch","build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --build --force"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-pp4cJOrjcivi2JpfbWHJWOr+F0XL/wIZrJOw9Bc8Q9vUOuGwqp5MAsZqzWhJl/VbTq+USLOH8K5kfUC8PW07lQ==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/azure-servicebus"},"_npmVersion":"10.8.3","description":"Azure Service Bus adapter for anyq","directories":{},"_nodeVersion":"26.3.0","dependencies":{"@anyq/core":"0.4.0","@azure/service-bus":"^7.9.4"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"0.4.0"},"_npmOperationalInternal":{"tmp":"tmp/azure-servicebus_0.4.0_1787860578454_0.9075952646259626","host":"s3://npm-registry-packages-npm-production"}},"0.5.0":{"name":"@anyq/azure-servicebus","version":"0.5.0","description":"Azure Service Bus adapter for anyq","type":"module","main":"./dist/index.js","module":"./dist/index.js","types":"./dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","build:types":"tsc --build --force","dev":"bun build ./src/index.ts --outdir ./dist --target bun --watch","typecheck":"tsc --noEmit","clean":"rm -rf dist"},"dependencies":{"@anyq/core":"0.5.0","@azure/service-bus":"^7.9.4"},"devDependencies":{"@types/bun":"latest","typescript":"^5.3.3"},"peerDependencies":{"@anyq/core":"0.5.0"},"keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"license":"Apache-2.0","author":"Shantanu Sharma","repository":{"type":"git","url":"https://github.com/sns45/anyq","directory":"packages/azure-servicebus"},"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"publishConfig":{"access":"public"},"_id":"@anyq/azure-servicebus@0.5.0","_integrity":"sha512-0oThCEYuDihSsVqYH6/tY3MWq8DK9sAMWZs+zBGijYNNLgiTnb5O5ZTZLiXfBW1mrpQ1LDwokxFG36zBH7w6tw==","_nodeVersion":"26.3.0","_npmVersion":"10.8.3","shasum":"f621cdab7c725ebd793c5ba2c218a05b12038218","dist":{"integrity":"sha512-0oThCEYuDihSsVqYH6/tY3MWq8DK9sAMWZs+zBGijYNNLgiTnb5O5ZTZLiXfBW1mrpQ1LDwokxFG36zBH7w6tw==","shasum":"f621cdab7c725ebd793c5ba2c218a05b12038218","tarball":"https://registry.npmjs.org/@anyq/azure-servicebus/-/azure-servicebus-0.5.0.tgz","fileCount":20,"unpackedSize":68168,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIHewHeSeebN8VONzt0UzNxKKwspFPOIduXx8d6ceU8q1AiEAuNAL1adH5DbD0JhevVzeXLIgRvCLQwSZoxgzyHwouhU="}]},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"directories":{},"maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/azure-servicebus_0.5.0_1788809002409_0.9675760715500048"},"_hasShrinkwrap":false}},"time":{"created":"2025-12-17T17:02:58.905Z","modified":"2026-09-07T19:23:22.729Z","0.1.0":"2025-12-17T17:02:59.153Z","0.1.1":"2025-12-17T17:09:49.891Z","0.3.0":"2026-06-20T13:26:23.205Z","0.3.1":"2026-06-21T15:10:06.288Z","0.3.2":"2026-07-24T16:24:36.260Z","0.4.0":"2026-08-27T19:56:18.594Z","0.5.0":"2026-09-07T19:23:22.541Z"},"bugs":{"url":"https://github.com/sns45/anyq/issues"},"author":"Shantanu Sharma","license":"Apache-2.0","homepage":"https://github.com/sns45/anyq#readme","keywords":["anyq","queue","message-queue","azure","service-bus","servicebus"],"repository":{"type":"git","url":"https://github.com/sns45/anyq","directory":"packages/azure-servicebus"},"description":"Azure Service Bus adapter for anyq","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"readme":"# @anyq/azure-servicebus\n\nAzure Service Bus adapter for **anyq** - enterprise cloud messaging.\n\n## Installation\n\n```bash\nnpm install @anyq/azure-servicebus @anyq/core @azure/service-bus\n```\n\n## Usage\n\n```typescript\nimport { AzureServiceBusProducer, AzureServiceBusConsumer } from '@anyq/azure-servicebus';\n\n// Create producer\nconst producer = new AzureServiceBusProducer({\n  connectionString: 'Endpoint=sb://my-namespace.servicebus.windows.net/;SharedAccessKeyName=...;SharedAccessKey=...',\n  queueName: 'my-queue'\n});\n\n// Create consumer\nconst consumer = new AzureServiceBusConsumer({\n  connectionString: 'Endpoint=sb://my-namespace.servicebus.windows.net/;SharedAccessKeyName=...;SharedAccessKey=...',\n  queueName: 'my-queue'\n});\n\nawait producer.connect();\nawait consumer.connect();\n\n// Subscribe to messages\nawait consumer.subscribe(async (message) => {\n  console.log('Received:', message.data);\n  console.log('Sequence:', message.metadata.sequenceNumber);\n  await message.ack();\n});\n\n// Publish messages\nawait producer.publish({\n  event: 'invoice.created',\n  invoiceId: 'INV-001'\n});\n\n// Publish with scheduling\nawait producer.publish(\n  { reminder: 'follow-up' },\n  { scheduledEnqueueTime: new Date(Date.now() + 3600000) }\n);\n\n// Cleanup\nawait consumer.disconnect();\nawait producer.disconnect();\n```\n\n## Configuration\n\n```typescript\ninterface AzureServiceBusConfig {\n  connectionString: string;   // Service Bus connection string\n  // Queue mode\n  queueName?: string;\n  // Topic/subscription mode\n  topicName?: string;\n  subscriptionName?: string;\n  // Consumer options\n  maxConcurrentCalls?: number;\n  autoComplete?: boolean;\n  maxAutoLockRenewalDuration?: number;\n  // Producer options\n  enablePartitioning?: boolean;\n}\n```\n\n## Features\n\n- Queues and Topics/Subscriptions\n- Scheduled messages\n- Sessions (ordered processing)\n- Dead letter queues\n- Duplicate detection\n- Auto-lock renewal\n- Message deferral\n\n## Retry strategies (0.3.0)\n\nThis adapter participates in the opt-in pluggable retry strategies from `@anyq/core`. Pass a strategy via `BaseQueueConfig.strategy` and `AzureServiceBusConsumer.applyStrategy()` takes over per-message error handling; omit it and the legacy catch behaviour (log; SDK abandons/dead-letters based on settings) runs unchanged.\n\n| Capability | Support |\n|---|---|\n| `supportsNativeDelay` | **false** (this release) |\n| `park` | downgrades to in-process retry with a `warn` log, capped by `maxAttempts`. The `scheduledEnqueueTimeUtc` implementation is a follow-up |\n| `deadLetterMessage` | default (`nack(false)` → message abandoned). Configure the entity's dead-letter sub-queue settings (`maxDeliveryCount`) if you want messages routed to the DLQ |\n\n```typescript\nimport { retryThenDeadLetter } from '@anyq/core';\n\nconst consumer = new AzureServiceBusConsumer({\n  connectionString: '...',\n  queueName: 'orders',\n  strategy: retryThenDeadLetter({ maxAttempts: 5 }),\n});\n```\n\nSee `@anyq/core` for the full strategy catalogue.\n\n## License\n\nApache License 2.0. See [LICENSE](https://github.com/sns45/anyq/blob/main/LICENSE).\n","readmeFilename":"README.md"}