{"_id":"@anyq/sqs","_rev":"7-37a0bfa14ea86dbe7b1c151cf0a0faba","name":"@anyq/sqs","dist-tags":{"latest":"0.5.0"},"versions":{"0.1.0":{"name":"@anyq/sqs","version":"0.1.0","keywords":["anyq","queue","sqs","aws","message-queue"],"author":{"name":"Shantanu Sharma"},"license":"MIT","_id":"@anyq/sqs@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":"47b0f1ee673a6871518bda8dff0e8a88e74a7bcb","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.1.0.tgz","fileCount":10,"integrity":"sha512-l6iOx+AAlSV4AKohxgVlPJTmS5vToynPh42jB95+xmjwwGpP6VV4hBsrI+PllhXrJUFUuNk0KmfQEtHJq20hGw==","signatures":[{"sig":"MEUCIA7+JAOfeQy35hm85HK+ycW0rGHXf50SWQyDNoCQjp20AiEA2Iu2s1teYiMgcOLzy0P3HlJAR9U1rLg7cha979OZBnA=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":1083660},"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"}},"gitHead":"1210b51fe4a55144ebf5bc798db0732b4c89ddba","scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"repository":{"url":"git+https://github.com/sns45/anyq.git","type":"git","directory":"packages/sqs"},"_npmVersion":"10.9.2","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"22.17.0","dependencies":{"@anyq/core":"workspace:*","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"workspace:*"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.1.0_1765990934540_0.05852925855606217","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@anyq/sqs","version":"0.1.1","keywords":["anyq","queue","sqs","aws","message-queue"],"author":{"name":"Shantanu Sharma"},"license":"MIT","_id":"@anyq/sqs@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":"a8b7b18448b10a2092a41dc6cb1770ec91cbc4d8","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.1.1.tgz","fileCount":11,"integrity":"sha512-1JZ82/gXZMcIsLSsIMYlylxQ/QJgpvN8Gt4cwTKOjgSQgAt2RDveJBuqmtBwHzwzpN+E2SGrdPdtqFiK6dv52w==","signatures":[{"sig":"MEUCIQC3wKIYBdASnPmJmEsXrHO9ksMe80dal3Ro4By4ivv6wAIgIaV6IkPlc9SXUoCfP4D3OA4mPBwSZeN6VqFP5njKm+U=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":1085329},"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"}},"gitHead":"30128d564178a5a1d25b736b605bf69644178a0f","scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"repository":{"url":"git+https://github.com/sns45/anyq.git","type":"git","directory":"packages/sqs"},"_npmVersion":"10.9.2","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"22.17.0","dependencies":{"@anyq/core":"workspace:*","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"workspace:*"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.1.1_1765991346089_0.01647589337718136","host":"s3://npm-registry-packages-npm-production"}},"0.3.0":{"name":"@anyq/sqs","version":"0.3.0","keywords":["anyq","queue","sqs","aws","message-queue"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/sqs@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":"2e70853d2a9c3258c948e5600ca0054afba29b93","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.3.0.tgz","fileCount":11,"integrity":"sha512-cn5HcHNDzJASFQqLXlx6u9zRW2DjkMuxsd+79nwkegl3eFakYS6ZVVfwUWxYlj+URElsorqsH9XpsCWILoP2Fw==","signatures":[{"sig":"MEUCIQCmMpYNC1Dvl8wvIkhgSyTWDFyOIO9YZhb/8ix3KUieSQIgC2wWwE26Ff/CrsPdzRteVRDpBLxvz1j0N48RdpOtGAE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":923691},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"2e70853d2a9c3258c948e5600ca0054afba29b93","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-cn5HcHNDzJASFQqLXlx6u9zRW2DjkMuxsd+79nwkegl3eFakYS6ZVVfwUWxYlj+URElsorqsH9XpsCWILoP2Fw==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/sqs"},"_npmVersion":"10.8.3","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.0","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"0.3.0"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.3.0_1781961973364_0.658957746842487","host":"s3://npm-registry-packages-npm-production"}},"0.3.1":{"name":"@anyq/sqs","version":"0.3.1","keywords":["anyq","queue","sqs","aws","message-queue"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/sqs@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":"4313cc6cb98485fc59370573ab2fbee1bd4a1952","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.3.1.tgz","fileCount":11,"integrity":"sha512-bbE0A11FzrIfRWuRgjdHnXyyVriv6rtSck2vjTZiWA18btZs8mKvhjgsE7WJ69XXlwH8kcDUCcA6NuaSRzGG5Q==","signatures":[{"sig":"MEYCIQDNiRULKIzlrRSWdBb+7yC8ACNxvn4I0IvUd9zaIR+z6AIhAKENPEnEY2K87yBEhT6PCXHz+RhhSvQzfEQ+/AOx3sB3","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":926453},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"4313cc6cb98485fc59370573ab2fbee1bd4a1952","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-bbE0A11FzrIfRWuRgjdHnXyyVriv6rtSck2vjTZiWA18btZs8mKvhjgsE7WJ69XXlwH8kcDUCcA6NuaSRzGG5Q==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/sqs"},"_npmVersion":"10.8.3","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.0","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"0.3.0"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.3.1_1782054597726_0.1922223379159802","host":"s3://npm-registry-packages-npm-production"}},"0.3.2":{"name":"@anyq/sqs","version":"0.3.2","keywords":["anyq","queue","sqs","aws","message-queue"],"author":"Shantanu Sharma","license":"MIT","_id":"@anyq/sqs@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":"38cf7d159dc62687afabd650484aef59a2fb55b5","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.3.2.tgz","fileCount":11,"integrity":"sha512-F8riJj6r381LmjplcNy4BZM+1LQMtpmVugBU1SWBiHPH7gRUws62MAcKS41V8yyBm8BIob6COcfahQoSxBZ+TQ==","signatures":[{"sig":"MEQCIAdFjG1ERUcBA1lFk6XwgzYcVtlJRoC/DxXSkdOknxPNAiBOW7+DMAsrJsvfZj30tVpAOV9IYRSlwC8qkp15/Rb1Cw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":926453},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"38cf7d159dc62687afabd650484aef59a2fb55b5","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-F8riJj6r381LmjplcNy4BZM+1LQMtpmVugBU1SWBiHPH7gRUws62MAcKS41V8yyBm8BIob6COcfahQoSxBZ+TQ==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/sqs"},"_npmVersion":"10.8.3","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"24.3.0","dependencies":{"@anyq/core":"0.3.2","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"0.3.2"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.3.2_1784910264674_0.6086948322051939","host":"s3://npm-registry-packages-npm-production"}},"0.4.0":{"name":"@anyq/sqs","version":"0.4.0","keywords":["anyq","queue","sqs","aws","message-queue"],"author":"Shantanu Sharma","license":"Apache-2.0","_id":"@anyq/sqs@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":"9da14af98545ea37484a36fb283de473ccc2129f","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.4.0.tgz","fileCount":13,"integrity":"sha512-Xx6lwGJRrjxqwRiLhXVFqk8E4/2kzUuFvkdXVaNUNEvMUmDxj5NaHgfbvdesZ+xE4DCWhMOZqDrexgbLljLq3A==","signatures":[{"sig":"MEQCIG0aCSlfsPuEg2cN5X+sz7BdYR97hmP95aBej2WcQ1BJAiBmzidbahjTSC98Ycoyrq8QK9rfPAnloMh3yk9f+KD8+A==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":939086},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","shasum":"9da14af98545ea37484a36fb283de473ccc2129f","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","clean":"rm -rf dist","typecheck":"tsc --noEmit","build:types":"tsc --emitDeclarationOnly --outDir dist"},"_npmUser":{"name":"sns45","email":"notifyshantanu@gmail.com"},"_integrity":"sha512-Xx6lwGJRrjxqwRiLhXVFqk8E4/2kzUuFvkdXVaNUNEvMUmDxj5NaHgfbvdesZ+xE4DCWhMOZqDrexgbLljLq3A==","repository":{"url":"https://github.com/sns45/anyq","type":"git","directory":"packages/sqs"},"_npmVersion":"10.8.3","description":"AWS SQS adapter for anyq","directories":{},"_nodeVersion":"26.3.0","dependencies":{"@anyq/core":"0.4.0","@aws-sdk/client-sqs":"^3.650.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"0.4.0"},"_npmOperationalInternal":{"tmp":"tmp/sqs_0.4.0_1787860567222_0.47069347142328666","host":"s3://npm-registry-packages-npm-production"}},"0.5.0":{"name":"@anyq/sqs","version":"0.5.0","description":"AWS SQS adapter for anyq","type":"module","main":"./dist/index.js","module":"./dist/index.js","types":"./dist/index.d.ts","exports":{".":{"import":"./dist/index.js","types":"./dist/index.d.ts"}},"scripts":{"build":"bun build ./src/index.ts --outdir ./dist --target bun && bun run build:types","build:types":"tsc --emitDeclarationOnly --outDir dist","typecheck":"tsc --noEmit","clean":"rm -rf dist"},"dependencies":{"@anyq/core":"0.5.0","@aws-sdk/client-sqs":"^3.650.0"},"devDependencies":{"@types/bun":"latest","typescript":"^5.4.5"},"peerDependencies":{"@anyq/core":"0.5.0"},"keywords":["anyq","queue","sqs","aws","message-queue"],"license":"Apache-2.0","author":"Shantanu Sharma","repository":{"type":"git","url":"https://github.com/sns45/anyq","directory":"packages/sqs"},"homepage":"https://github.com/sns45/anyq#readme","bugs":{"url":"https://github.com/sns45/anyq/issues"},"publishConfig":{"access":"public"},"_id":"@anyq/sqs@0.5.0","_integrity":"sha512-QkIzXoDgpMt0EKbBNEGITmHZyC1sd9/VPAGD4Bu7LAfyEpl/mmB+wfPMqnRNmK/J+e64H8sLDkbDcXigzNUlww==","_nodeVersion":"26.3.0","_npmVersion":"10.8.3","shasum":"7bd6f711fc6720343b33158fc8816d67a26b718c","dist":{"integrity":"sha512-QkIzXoDgpMt0EKbBNEGITmHZyC1sd9/VPAGD4Bu7LAfyEpl/mmB+wfPMqnRNmK/J+e64H8sLDkbDcXigzNUlww==","shasum":"7bd6f711fc6720343b33158fc8816d67a26b718c","tarball":"https://registry.npmjs.org/@anyq/sqs/-/sqs-0.5.0.tgz","fileCount":13,"unpackedSize":932314,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEYCIQCvggCLKEYG5svjNhoV1rrCs4CNE+7+YJHyFuS/vKaGlQIhAKGXUD68XW8Qu8kpxXrbaW3P+F6R6IPW/XD2iM8aUo+9"}]},"_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/sqs_0.5.0_1788808993086_0.0318307434332501"},"_hasShrinkwrap":false}},"time":{"created":"2025-12-17T17:02:14.479Z","modified":"2026-09-07T19:23:13.393Z","0.1.0":"2025-12-17T17:02:14.699Z","0.1.1":"2025-12-17T17:09:06.277Z","0.3.0":"2026-06-20T13:26:13.566Z","0.3.1":"2026-06-21T15:09:57.967Z","0.3.2":"2026-07-24T16:24:24.903Z","0.4.0":"2026-08-27T19:56:07.362Z","0.5.0":"2026-09-07T19:23:13.231Z"},"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","sqs","aws","message-queue"],"repository":{"type":"git","url":"https://github.com/sns45/anyq","directory":"packages/sqs"},"description":"AWS SQS adapter for anyq","maintainers":[{"name":"sns45","email":"notifyshantanu@gmail.com"}],"readme":"# @anyq/sqs\n\nAWS SQS adapter for **anyq** - fully managed cloud queuing.\n\n## Installation\n\n```bash\nnpm install @anyq/sqs @anyq/core @aws-sdk/client-sqs\n```\n\n## Usage\n\n```typescript\nimport { SQSProducer, SQSConsumer } from '@anyq/sqs';\n\n// Create producer\nconst producer = new SQSProducer({\n  region: 'us-east-1',\n  queueUrl: 'https://sqs.us-east-1.amazonaws.com/123456789/my-queue'\n});\n\n// Create consumer\nconst consumer = new SQSConsumer({\n  region: 'us-east-1',\n  queueUrl: 'https://sqs.us-east-1.amazonaws.com/123456789/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  await message.ack();\n});\n\n// Publish messages\nawait producer.publish({\n  event: 'payment.processed',\n  amount: 99.99\n});\n\n// Batch publish\nawait producer.publishBatch([\n  { item: 1 },\n  { item: 2 }\n]);\n\n// Cleanup\nawait consumer.disconnect();\nawait producer.disconnect();\n```\n\n## Configuration\n\n```typescript\ninterface SQSConfig {\n  region: string;              // AWS region\n  queueUrl: string;            // Full SQS queue URL\n  credentials?: {\n    accessKeyId: string;\n    secretAccessKey: string;\n  };\n  visibilityTimeout?: number;  // Seconds (default: 30)\n  waitTimeSeconds?: number;    // Long polling (default: 20)\n  maxMessages?: number;        // Messages per poll (1-10)\n  // FIFO queue options\n  messageGroupId?: string;\n  deduplicationId?: string;\n}\n```\n\n## Features\n\n- Standard and FIFO queues\n- Long polling\n- Batch operations (up to 10 messages)\n- Visibility timeout management\n- Dead letter queues\n- Message deduplication (FIFO)\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 `SQSConsumer.applyStrategy()` takes over per-message error handling; omit it and the legacy catch behaviour (log + emit `error`; visibility timeout governs redelivery) runs unchanged.\n\n| Capability | Support |\n|---|---|\n| `supportsNativeDelay` | **true** |\n| Native `park` | re-publishes the message with `SendMessage` `DelaySeconds` (capped at 900s) and deletes the in-flight copy |\n| `deadLetterMessage` | default (`nack(false)` → `DeleteMessage`). Configure an SQS redrive policy on the queue if you want messages routed to a dedicated DLQ |\n\n```typescript\nimport { backpressurePause } from '@anyq/core';\n\nconst consumer = new SQSConsumer({\n  driver: 'sqs',\n  queueUrl: '...',\n  sqs: { region: 'us-east-1' },\n  strategy: backpressurePause({ pauseMs: 30_000 }),\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"}