{"_id":"@bakerstreet-industries/bus-rabbitmq","_rev":"1-e4cd449b91ea792365a1241a0ca41823","name":"@bakerstreet-industries/bus-rabbitmq","dist-tags":{"latest":"1.0.16"},"versions":{"1.0.16":{"name":"@bakerstreet-industries/bus-rabbitmq","description":"A RabbitMQ transport adapter for @node-ts/bus-core.","version":"1.0.16","license":"MIT","main":"./dist/index.js","types":"./dist/index.d.ts","repository":{"type":"git","url":"git+https://github.com/bakerstreet-industries/bus.git"},"scripts":{"clean":"rm -rf dist","build":"tsc --project tsconfig.json --declaration","build:watch":"yarn run build --incremental --watch --preserveWatchOutput","lint":"tslint --project tsconfig.json 'src/**/*.ts'","lint:fix":"yarn lint --fix"},"publishConfig":{"access":"public"},"dependencies":{"@node-ts/bus-messages":"^1.0.4","@types/amqplib":"^0.8.2","amqplib":"^0.8.0","tslib":"^1.9.3","uuid":"^3.3.2"},"devDependencies":{"@node-ts/bus-core":"^1.0.12","@node-ts/bus-test":"^0.0.16","@node-ts/code-standards":"^0.0.10","@types/faker":"^4.1.5","@types/uuid":"^3.4.4","faker":"^4.1.0","reflect-metadata":"^0.1.13","typemoq":"^2.1.0","typescript":"^4.3.5"},"peerDependencies":{"@node-ts/bus-core":"^1.0.0-alpha.0"},"keywords":["esb","rabbitmq","typescript","enterprise integration patterns","bus","messaging","microservices","distributed systems","framework","enterprise framework","CQRS","ES","NServiceBus","Mule ESB"],"gitHead":"22878835e97f47c5d0cb2aac8b222a0765e1e8fc","bugs":{"url":"https://github.com/bakerstreet-industries/bus/issues"},"homepage":"https://github.com/bakerstreet-industries/bus#readme","_id":"@bakerstreet-industries/bus-rabbitmq@1.0.16","_nodeVersion":"14.18.1","_npmVersion":"lerna/4.0.0/node@v14.18.1+arm64 (darwin)","dist":{"integrity":"sha512-FdgymqzbxK7eTyixZjf+cZOhS4tM3OGDE8pyTOhKg3WCqba3OS+QDFgsYJJsR5nPGT/qJ1H+GhQtPLkNfYAoaQ==","shasum":"d2201941b71d7821e3a7d2f764d24de897f5557c","tarball":"https://registry.npmjs.org/@bakerstreet-industries/bus-rabbitmq/-/bus-rabbitmq-1.0.16.tgz","fileCount":18,"unpackedSize":35432,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJiB+9iCRA9TVsSAnZWagAAnCoP/0MDIvs2tYEWLDdC51Nv\nsoLg/84P7a7mteKIPzPuAFTQQLtPYefy3b1yS+QLDMvz/92LOO2ak9uz1ebq\nlYR1mjA9f/vfoDyt5JQQ2e/Yk9mpRoZ54SYndRfhRjUv4FqIkKNSfyLB5mHi\nQbBEpPG89Qa4V79n7NQxnnpdkQ854r5HupjZstIFhAKtlY55T+4Nw32SYlp0\naaQyEG2gF/Mv/bDeEHN2o3EZ5Dv60XAUHb4wen/DB1ImYgCO+G6vBz9Hv/IK\nKjnRGMvZLV+tdsz5OnLKXzUpd8IIT4Ka4KsogjiyXqT3W4TRnUcSE3gYzBEJ\nVnRabqRoNMJHb7pCq7B/aMnLm/SruYZEN4MyadPAlBZFkp6y/41MP7FEZTnz\n4AVAEqHCJNByw2jneYKToZQ/WZRFsLtDGKWDkHbXRc/UxNhFaIWm90pyZoL6\nu24K/vjyz/10s5Ngu+iEu6CNYZ2QBW51g9V8362WErSKnRh0z75oxH0dofz0\nQdhfeZc59UdDuFTsHKW1ZRB0aJjPj+saSjHGEWOui8Oz+fZXBUDKIK4CE0h/\nE24IJgVS/xtPA7YwFahRogFXK3WIP7dzzfpd7H9o5YO7zWsbHucaPwG0dKbk\nwAR7tOm4BXnMkLoc4HIvcC3BPQAgPG1y0nWh67pRcDqIzuPrAUCH/QOJqWvD\n0pyI\r\n=001j\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDrUMGSfZFK0r8o057+uX/szuNoL5cS7yQ349LJMDQUHAiEA/uhjCaXU1IxCQB1/dS3GnXWaeCI6mnDWoBkoEyedhA0="}]},"_npmUser":{"name":"roustalski","email":"russ@bakerstreet.industries"},"directories":{},"maintainers":[{"name":"roustalski","email":"russ@bakerstreet.industries"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/bus-rabbitmq_1.0.16_1644687202584_0.6375713222871664"},"_hasShrinkwrap":false}},"time":{"created":"2022-02-12T17:33:22.520Z","1.0.16":"2022-02-12T17:33:22.777Z","modified":"2022-04-04T17:32:07.639Z"},"maintainers":[{"name":"roustalski","email":"russ@bakerstreet.industries"}],"description":"A RabbitMQ transport adapter for @node-ts/bus-core.","homepage":"https://github.com/bakerstreet-industries/bus#readme","keywords":["esb","rabbitmq","typescript","enterprise integration patterns","bus","messaging","microservices","distributed systems","framework","enterprise framework","CQRS","ES","NServiceBus","Mule ESB"],"repository":{"type":"git","url":"git+https://github.com/bakerstreet-industries/bus.git"},"bugs":{"url":"https://github.com/bakerstreet-industries/bus/issues"},"license":"MIT","readme":"# @node-ts/bus-rabbitmq\n\nA Rabbit MQ transport adapter for [@node-ts/bus](https://bus.node-ts.com)\n\n🔥 View our docs at [https://bus.node-ts.com](https://bus.node-ts.com) 🔥\n\n🤔 Have a question? [Join our Discord](https://discord.gg/Gg7v4xt82X) 🤔\n\n## Installation\n\nInstall all packages and their dependencies\n\n```bash\nnpm install @node-ts/bus-rabbitmq\n```\n\nOnce installed, configure a new `RabbitMqTransport` and register it for use with `Bus`:\n\n```typescript\nimport { Bus } from '@node-ts/bus-core'\nimport { RabbitMqTransport, RabbitMqTransportConfiguration } from '@node-ts/bus-rabbitmq'\n\nconst rabbitConfiguration: RabbitMqTransportConfiguration = {\n  queueName: 'accounts-application-queue',\n  connectionString: 'amqp://guest:guest@localhost',\n  maxRetries: 5\n}\nconst rabbitMqTransport = new RabbitMqTransport(rabbitConfiguration)\n\n// Configure Bus to use RabbitMQ as a transport\nconst run = async () => {\n  await Bus\n    .configure()\n    .withTransport(rabbitMqTransport)\n    .initialize()\n}\nrun.catch(console.error)\n```\n\n## Configuration Options\n\nThe RabbitMQ transport has the following configuration:\n\n*  **queueName** *(required)* The name of the service queue to create and read messages from.\n*  **connectionString** *(required)* An amqp formatted connection string that's used to connect to the RabbitMQ instance\n* **maxRetries** *(optional)* The number of attempts to retry failed messages before they're routed to the dead letter queue. *Default: 10*\n\n## Development\n\nLocal development can be done with the aid of docker to run the required infrastructure. To do so, run:\n\n```bash\ndocker run -d -p 8080:15672 -p 5672:5672 rabbitmq:3-management\n```","readmeFilename":"README.md"}