{"_id":"@apinecka/amqp","_rev":"2-deb0fa7ee4708da0604fdf362c1469ea","name":"@apinecka/amqp","dist-tags":{"latest":"1.0.1"},"versions":{"1.0.0":{"name":"@apinecka/amqp","version":"1.0.0","keywords":["nestjs","amqp","rabbitmq","amqp-connection-manager"],"author":{"name":"Tomáš Cupák","email":"tomcupak@gmail.com"},"license":"MIT","_id":"@apinecka/amqp@1.0.0","maintainers":[{"name":"tomcupak","email":"tomcupak@gmail.com"}],"homepage":"https://github.com/tomcupak/apinecka-libs/tree/master/libs/amqp#readme","bugs":{"url":"https://github.com/tomcupak/apinecka-libs/issues"},"dist":{"shasum":"4dc0f7de8c95c5671752815f25fd6ef212a1406c","tarball":"https://registry.npmjs.org/@apinecka/amqp/-/amqp-1.0.0.tgz","fileCount":3,"integrity":"sha512-2GjlJym06jIZEMuwYJpgR+az7GNDEitDbZvit4gGvonq3GRRND4Dtsf/rX/t1RsfjFh09cKcaxtYdmrI81QWag==","signatures":[{"sig":"MEQCIHSFjMeZqo0VgfgZHY06DplnF6rDYByc0fz0FBT+BmzgAiBgOBRlxY+GoWylo4SquxKO//qVBHdI9RsDiWLpaUjdTA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":3829},"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","default":"./dist/index.js"}},"gitHead":"82ccf626ab2f0739fb0f0a6bcb61348530d353ad","scripts":{"build":"tsc","clean":"del-cli dist","prepublishOnly":"npm run clean && npm run build"},"_npmUser":{"name":"tomcupak","email":"tomcupak@gmail.com"},"repository":{"url":"git+https://github.com/tomcupak/apinecka-libs.git","type":"git","directory":"libs/amqp"},"_npmVersion":"11.6.1","description":"NestJS module for AMQP/RabbitMQ: declarative exchange/queue/binding schemas, decorator-based consumers, batch consumers, and publish helpers on top of amqp-connection-manager.","directories":{},"_nodeVersion":"24.10.0","publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"amqplib":"^2.0.1","del-cli":"^7.0.0","typescript":"^5.8.3","@types/node":"^22.15.33","@nestjs/core":"^11.1.7","@nestjs/common":"^11.1.7","amqp-connection-manager":"^4.1.15"},"peerDependencies":{"amqplib":"*","@nestjs/core":"^11.0.0","@nestjs/common":"^11.0.0","amqp-connection-manager":"^4.1"},"_npmOperationalInternal":{"tmp":"tmp/amqp_1.0.0_1785872458041_0.5191681189798363","host":"s3://npm-registry-packages-npm-production"}},"1.0.1":{"name":"@apinecka/amqp","version":"1.0.1","description":"NestJS module for AMQP/RabbitMQ: declarative exchange/queue/binding schemas, decorator-based consumers, batch consumers, and publish helpers on top of amqp-connection-manager.","keywords":["nestjs","amqp","rabbitmq","amqp-connection-manager"],"main":"dist/index.js","types":"dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","default":"./dist/index.js"}},"scripts":{"build":"tsc","clean":"del-cli dist","prepublishOnly":"npm run clean && npm run build"},"author":{"name":"Tomáš Cupák","email":"tomcupak@gmail.com"},"license":"MIT","repository":{"type":"git","url":"git+https://github.com/tomcupak/apinecka-libs.git","directory":"libs/amqp"},"homepage":"https://github.com/tomcupak/apinecka-libs/tree/master/libs/amqp#readme","bugs":{"url":"https://github.com/tomcupak/apinecka-libs/issues"},"publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^11.0.0","@nestjs/core":"^11.0.0","amqp-connection-manager":"^4.1","amqplib":"*"},"devDependencies":{"@nestjs/common":"^11.1.7","@nestjs/core":"^11.1.7","amqp-connection-manager":"^4.1.15","amqplib":"^2.0.1","del-cli":"^7.0.0","typescript":"^5.8.3","@types/node":"^22.15.33"},"gitHead":"6e8bd70bcdf580396775598e520b8be2331d7a74","_id":"@apinecka/amqp@1.0.1","_nodeVersion":"24.10.0","_npmVersion":"11.6.1","dist":{"integrity":"sha512-sQ3ml/rPTDbZ3BNzc1RyyMBGLfTtp5423hyhvMDehnw8P1S8VOpeO5RcOx6BW34wmVkbZyHIrwyExhrcbnRgyg==","shasum":"13b434b1a7572db5d74476da60ed774220a44d2f","tarball":"https://registry.npmjs.org/@apinecka/amqp/-/amqp-1.0.1.tgz","fileCount":22,"unpackedSize":156348,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEQCICKJt4SkGHGyYCgPMPzU21AWSavDd4yCjuJSSPSdy8W4AiBwk+gw2GtzJzErR+kGq/syBE4L72qOsnPqRK7EE9Pi8g=="}]},"_npmUser":{"name":"tomcupak","email":"tomcupak@gmail.com"},"directories":{},"maintainers":[{"name":"tomcupak","email":"tomcupak@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/amqp_1.0.1_1785875747381_0.4177037763910534"},"_hasShrinkwrap":false}},"time":{"created":"2026-08-04T19:40:57.768Z","modified":"2026-08-04T20:35:47.707Z","1.0.0":"2026-08-04T19:40:58.173Z","1.0.1":"2026-08-04T20:35:47.543Z"},"bugs":{"url":"https://github.com/tomcupak/apinecka-libs/issues"},"author":{"name":"Tomáš Cupák","email":"tomcupak@gmail.com"},"license":"MIT","homepage":"https://github.com/tomcupak/apinecka-libs/tree/master/libs/amqp#readme","keywords":["nestjs","amqp","rabbitmq","amqp-connection-manager"],"repository":{"type":"git","url":"git+https://github.com/tomcupak/apinecka-libs.git","directory":"libs/amqp"},"description":"NestJS module for AMQP/RabbitMQ: declarative exchange/queue/binding schemas, decorator-based consumers, batch consumers, and publish helpers on top of amqp-connection-manager.","maintainers":[{"name":"tomcupak","email":"tomcupak@gmail.com"}],"readme":"# @apinecka/amqp\n\nNestJS module for AMQP/RabbitMQ built on top of\n[`amqp-connection-manager`](https://www.npmjs.com/package/amqp-connection-manager): declarative\nexchange/queue/binding schemas, decorator-based consumers, batch consumers, and a small\npublish helper.\n\n## Install\n\n```bash\nnpm install @apinecka/amqp amqp-connection-manager amqplib @nestjs/common @nestjs/core\n```\n\n## Usage\n\n```ts\nimport { AmqpModule, AmqpSchema } from '@apinecka/amqp'\n\nconst schema = AmqpSchema.create()\n\t.addQueue({ name: 'logs.publish', prefetch: 100 })\n\n@Module({\n\timports: [\n\t\tAmqpModule.forRoot({\n\t\t\turls: ['amqp://user:pass@host/vhost'],\n\t\t\tschema,\n\t\t}),\n\t],\n})\nexport class AppModule {}\n```\n\nConsume a queue with a decorator on any provider/controller method:\n\n```ts\nimport { AmqpConsumer } from '@apinecka/amqp'\n\n@AmqpConsumer(schema.queues['logs.publish'])\nasync handle(data: LogEntry) {\n\t// ...\n}\n```\n\nSee `src/amqp.decorators.ts` for the full set of decorators (single-message and batch\nconsumers) and `src/amqp.schema.ts` for building exchange/queue/binding schemas.\n\n## Peer dependencies\n\n- `@nestjs/common` and `@nestjs/core` — the module and decorators are NestJS-specific.\n- `amqp-connection-manager` — connection/channel management with auto-reconnect.\n- `amqplib` — required transitively by `amqp-connection-manager`.\n\n## License\n\nMIT\n","readmeFilename":"README.md"}