{"_id":"@aiondigital/messaging-queues","_rev":"13-8c0c6bc8d9038e1f765d85642817a083","name":"@aiondigital/messaging-queues","dist-tags":{"latest":"1.1.5"},"versions":{"1.0.0":{"name":"@aiondigital/messaging-queues","version":"1.0.0","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"806381e1dc2935c6e1ab20f534a073b5dfc7c148","_id":"@aiondigital/messaging-queues@1.0.0","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-fUfTpue5dAc9WXBgMROJdlVXfWXw2Z1f5FggXCi7hCcOo4drqq+DrBOG7LTmHQSqxUFXzFZ1kbgedum/XLhwMg==","shasum":"8ffdd92701c69dd6eed6689bbece82f852b7f798","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.0.tgz","fileCount":69,"unpackedSize":47812,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCHU47ByoPoTkIPiw9WOTh05dBxr9ODPDxUNaV1AUwLaAIgAxxZ+jXcbRQ1x/nSjeRAKQvjfyxAGErdKJIJOzHfN3o="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.0_1697379987093_0.3132789282893047"},"_hasShrinkwrap":false},"1.0.1":{"name":"@aiondigital/messaging-queues","version":"1.0.1","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.1","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-A25NaPwmr9lR4QDaF1NGx94Ib2OATP46Ww1dNsVl15NKSNpSVxXICT4Y9Zp0DIiC8Ll07yKDMMNrHxIh4HpyVw==","shasum":"5fa921d0fa6664736dfdaad74b83dfe42b404b9c","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.1.tgz","fileCount":70,"unpackedSize":163297,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCID1FyMjAXw0q/EVFE8jXF3cgrXtTHwlYtL+wTg+H5fnIAiAgk7byHg5HF4WIkFRoGPkGRtkwVvYsWLXlo1IZJm029A=="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.1_1697436251177_0.6392221095598039"},"_hasShrinkwrap":false},"1.0.2":{"name":"@aiondigital/messaging-queues","version":"1.0.2","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.2","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-w1NSWoXnqwnE+M1gxDRd+SjVToxXbN7HnnRDjc+5wlxByFO1RWTdnAXtDNYbrvxLU0mGWvoD5AhwqFlJGXIJQg==","shasum":"faf47fc16b2d2e511d6ed3c83239aa4c16bd4eb6","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.2.tgz","fileCount":74,"unpackedSize":165163,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCPDyZFjpilx3koKc6HJOeZoI1Pd2QHA1XdcFGyk6oFEgIgQFAUGj6fCb0i6zAyYHnQtsElzbYmfOxX6X/KtdnzRAM="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.2_1697440678303_0.624597581000395"},"_hasShrinkwrap":false},"1.0.3":{"name":"@aiondigital/messaging-queues","version":"1.0.3","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.3","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-cEshd7gHRaHr0OBKVCbkOUj0Su2guE9wmSZzrxnd3WMisKEu8P4tESh8CsTE9QMOK1jfEgqgDHob6f3XebS8kQ==","shasum":"0080f9e8d076749314a1b402daa6cb3c7fc5113c","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.3.tgz","fileCount":74,"unpackedSize":174380,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDXfipa1QIcoZa4gBgv2hs4mX4RA+4xXq4ar19S2dygWAiEAs3X1nY5n64LnT69qiZSM6Gxk3s5/fzzefKqxtyBNVBE="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.3_1697483960100_0.9192105987023524"},"_hasShrinkwrap":false},"1.0.4":{"name":"@aiondigital/messaging-queues","version":"1.0.4","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.4","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-aRECQk6pOUdfxZEBANos2vTctLOi/DJ0US2RQaG64v1VfHdVjuEUPMbkfhV33XHrjFNRrYDw9OWAI8/IZHe9Gw==","shasum":"b190be694b49f18c93502fa6fd909559d9b815b4","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.4.tgz","fileCount":74,"unpackedSize":174380,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDgfDAfAVnTAPURP5WbJ2uAA6/TLSKQUWzzYNigzCspTAIgb6H5ioklE6+AzkJBUxkMKdeiL/FMCKrtuCB0ORhDh54="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.4_1697484356493_0.3894326937124648"},"_hasShrinkwrap":false},"1.0.5":{"name":"@aiondigital/messaging-queues","version":"1.0.5","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.5","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-CHvDvelHeGz3Z/YZz208sPYA3OxVA6D9gjHAEWyPQfdf+PtbfrPDoGDVnWiy249UhUZeWQ2/2AbyiT4mMas4pA==","shasum":"52fa8474a73fd9608a10c9b1abfadf2afa27e968","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.5.tgz","fileCount":74,"unpackedSize":174380,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCX5wqPcZHITsKf+3oPqP0IRDNu0UuKgqbnwc0qTLqtSgIhANxz4I3sjkMv/TNl6pFtGt8xpNyo5PtuLcK+DZpT1DSY"}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.5_1697484675678_0.7121697235412072"},"_hasShrinkwrap":false},"1.0.6":{"name":"@aiondigital/messaging-queues","version":"1.0.6","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.6","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-JB9E8ObbzMB/bTa2vhmzi2tHk0anEsOs+hUEjypyNviEgtxrhzx3ELGD089ZRu8Nz3sBuyRAL/gv1q8dayUstw==","shasum":"0d12c3e7fdc8ed6c695a58f68a3b494dd7982243","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.6.tgz","fileCount":74,"unpackedSize":174898,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCJSRAPRl/HC+TJT4642uMPOV6JIXAHPfA/WZCTTQxZTwIhAN+79YFnO2XxXMGPD9ugU6GZar1MtuRDjdlouH8Hu/W7"}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.6_1697484974028_0.11776104385955377"},"_hasShrinkwrap":false},"1.0.7":{"name":"@aiondigital/messaging-queues","version":"1.0.7","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.7","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-6mOklaseIfYEmydfX11+6LFJ8CF+mH5EsuyiI+sOVVxEuFsDZJ5gJJT9LJtleFaA32kJF4Pv5czkMqqo4ksVHQ==","shasum":"02433b5011646d1decc275cba14bb08c7ede9be9","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.7.tgz","fileCount":74,"unpackedSize":175172,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG4DesMko73PoRr8hfPX86FGASAFoKiHHfsQfJ2YC9K9AiBgDNZdh+92XZoT4eelqtRupHRcpY0UiwmY99BxbeveYg=="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.7_1697486286848_0.708035688241577"},"_hasShrinkwrap":false},"1.0.8":{"name":"@aiondigital/messaging-queues","version":"1.0.8","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"fd1c078ce4921d7678fbd504b3eb432ff6a00c22","_id":"@aiondigital/messaging-queues@1.0.8","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-k/8joU18Ctlib0qA055w6Wsg35ku1XOfdy7t+Y/1pWclm4faF4IYDB2jtPQt317bzuwhaAQuYJvy6Hot28IXpA==","shasum":"edb1d13c03a4bdef5e19b4a44c5926bca871763a","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.8.tgz","fileCount":74,"unpackedSize":175184,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD66uzpCC3ssoybj+d5pkeowrMPGbWLgNKax2AcV8YosQIgcM56W5EJy4DoS8DdOeCkLsxGwxL/ZkO7yZTk2feekp0="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.8_1697486487679_0.052462083110092594"},"_hasShrinkwrap":false},"1.0.9":{"name":"@aiondigital/messaging-queues","version":"1.0.9","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"gitHead":"8cbaac2486eb42a1bc84f5d1daef69dfd0782651","_id":"@aiondigital/messaging-queues@1.0.9","_nodeVersion":"16.20.2","_npmVersion":"8.19.4","dist":{"integrity":"sha512-P3wgacxK1JzXIvoDyEJvdhUWfjaEbfDJgVKibSqXsWmv8W+q9M3KHaHJw74fp1qOdNfXjADkugqv9ogMUQwsNQ==","shasum":"9f3e3f6973cfb2de821f24576180b297dfe6d67b","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.0.9.tgz","fileCount":75,"unpackedSize":179525,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD4KsosYDeqfBH8jt5zjwh6ahAJFEygzSqv0Ur/tMzLuQIgFwefFdMvOVpCSN1pG4nnzfdan6M39IzD+TpTMh26pJg="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.0.9_1697528702525_0.13476931783838242"},"_hasShrinkwrap":false},"1.1.0":{"name":"@aiondigital/messaging-queues","version":"1.1.0","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"_id":"@aiondigital/messaging-queues@1.1.0","gitHead":"2fff155c9f32563a3530463c9b0f5d198cf9caa6","_nodeVersion":"20.8.0","_npmVersion":"10.1.0","dist":{"integrity":"sha512-yXhEfwY9qc3UBRwUne4KGsIrjVAnavZNUoff6PugpkGBCSHflaqqLr+GP+jln87CK3gVbxlelIg+4IsUPZV0Qg==","shasum":"bc699a262c33c1567d7c3fc9207cc3948e94af13","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.1.0.tgz","fileCount":75,"unpackedSize":179525,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCRupL5Dfih6UcMV9ZR64HebKldpRPjb/fzc5G+Z2S57AIgeeta+/aY/mYwdeTRPuze/RM6xaNViellZIgeaRjfC3Q="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.1.0_1697529158090_0.6908175435061961"},"_hasShrinkwrap":false},"1.1.3":{"name":"@aiondigital/messaging-queues","version":"1.1.3","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","repository":{"type":"git","url":"git+https://github.com/wjamilaion/rubix-messaging-queues.git"},"peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"_id":"@aiondigital/messaging-queues@1.1.3","gitHead":"40a33ce92e4d3393d64fa8f89729d2b23b969f14","bugs":{"url":"https://github.com/wjamilaion/rubix-messaging-queues/issues"},"homepage":"https://github.com/wjamilaion/rubix-messaging-queues#readme","_nodeVersion":"20.11.0","_npmVersion":"10.2.4","dist":{"integrity":"sha512-9iEilyySMnz1r3+Imji0Rb99obxnkpfhZkPnh5TP5ALJrfUFR7AXuEj2zJS2lLKLw/JYdIkhuPDtwhXLKdA10g==","shasum":"a46e818742e541f3bcafa6f13dd2909fa7abe8e3","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.1.3.tgz","fileCount":75,"unpackedSize":179730,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDIWeJ4dEZmA7gpOtNP4BcVh+f9YOzo51bEbAoOrxsrkAiAKj/d2aOj1zMCqdcRQlzHNKzRd02cHrnA+mvh/Ql7KSA=="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.1.3_1707725979415_0.1266067834093434"},"_hasShrinkwrap":false},"1.1.4":{"name":"@aiondigital/messaging-queues","version":"1.1.4","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","repository":{"type":"git","url":"git+https://github.com/wjamilaion/rubix-messaging-queues.git"},"peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"_id":"@aiondigital/messaging-queues@1.1.4","gitHead":"9602a92378f8b7a011e3d3b69e3d37a6416a1c42","bugs":{"url":"https://github.com/wjamilaion/rubix-messaging-queues/issues"},"homepage":"https://github.com/wjamilaion/rubix-messaging-queues#readme","_nodeVersion":"20.12.2","_npmVersion":"10.5.0","dist":{"integrity":"sha512-eEuxfLyGLVfGMny5uhPnuEe2jAfgrTGTAW/ZiXAYNzVjH08l3cPuq2XE9wlwTDu6ouv+b+XnyxIlf+evG5f8Wg==","shasum":"2a8ad01382687665c6364f3e210a2967aaabee85","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.1.4.tgz","fileCount":75,"unpackedSize":179930,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGXzjN8z3S4PH3i0FizUIrC4BJfxGttB5aHG5rCIusBDAiAThDETsHgf67FrKJQMR/KP27MGJgWVL5cFtaKdbu0G/g=="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.1.4_1713696530913_0.7584505814950635"},"_hasShrinkwrap":false},"1.1.5":{"name":"@aiondigital/messaging-queues","version":"1.1.5","description":"messaging queues based on different message brokers","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"rimraf dist && tsc","tsc":"tsc","test":"echo \"Error: no test specified\" && exit 1","format":"prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status","lint":"eslint \"**/*.{ts,tsx}\"","prepublish":"npm run build"},"keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","repository":{"type":"git","url":"git+https://github.com/wjamilaion/rubix-messaging-queues.git"},"peerDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","amqplib":"^0.10.3","bull":"^3.3 || ^4.0.0"},"devDependencies":{"@nestjs/common":"^10.2.7","@nestjs/core":"^10.2.7","@types/amqplib":"^0.10.2","@types/bull":"3.15.9","@types/node":"^20.8.6","@typescript-eslint/eslint-plugin":"^6.7.5","@typescript-eslint/parser":"^6.7.5","bull":"4.11.3","eslint":"^8.51.0","eslint-config-prettier":"^9.0.0","eslint-plugin-import":"^2.28.1","prettier":"^3.0.3","ts-loader":"^9.5.0","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.2.2"},"lint-staged":{"**/*.ts":["prettier --ignore-path ./.prettierignore --write"]},"dependencies":{"rimraf":"^5.0.5"},"_id":"@aiondigital/messaging-queues@1.1.5","gitHead":"ab0e1963ab8f7786b022598aa0ffc44a91cde8d5","bugs":{"url":"https://github.com/wjamilaion/rubix-messaging-queues/issues"},"homepage":"https://github.com/wjamilaion/rubix-messaging-queues#readme","_nodeVersion":"20.12.2","_npmVersion":"10.5.0","dist":{"integrity":"sha512-cdbt3Gq7FLt8coRtNdmdhK3lASTsjl48jAlRySsV+lUuI6p/eTQF+zzbCBWFGOKfTNPGq8+fjq0F1WQodDJ+7g==","shasum":"00f2c608f9b18d1b680027526375df307d6e9b15","tarball":"https://registry.npmjs.org/@aiondigital/messaging-queues/-/messaging-queues-1.1.5.tgz","fileCount":75,"unpackedSize":179930,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAX4pXXOYORw//iX2B8RImCUJck9srz/4q6abLw9qLUyAiEA42ftSt68I2+XKu88GeKFgxC3aMkDszuZAB91UOvCRWg="}]},"_npmUser":{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"},"directories":{},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/messaging-queues_1.1.5_1714416204143_0.09272991182956591"},"_hasShrinkwrap":false}},"time":{"created":"2023-10-15T14:26:26.976Z","1.0.0":"2023-10-15T14:26:27.283Z","modified":"2024-04-29T18:43:24.470Z","1.0.1":"2023-10-16T06:04:11.441Z","1.0.2":"2023-10-16T07:17:58.659Z","1.0.3":"2023-10-16T19:19:20.319Z","1.0.4":"2023-10-16T19:25:56.718Z","1.0.5":"2023-10-16T19:31:16.125Z","1.0.6":"2023-10-16T19:36:14.223Z","1.0.7":"2023-10-16T19:58:07.088Z","1.0.8":"2023-10-16T20:01:27.912Z","1.0.9":"2023-10-17T07:45:02.877Z","1.1.0":"2023-10-17T07:52:38.480Z","1.1.3":"2024-02-12T08:19:39.607Z","1.1.4":"2024-04-21T10:48:51.091Z","1.1.5":"2024-04-29T18:43:24.295Z"},"maintainers":[{"name":"waqasjamil","email":"waqas.jamil47@gmail.com"}],"description":"messaging queues based on different message brokers","keywords":["messaging","queues","rabbitmq","bull"],"author":{"name":"waqas jamil"},"license":"ISC","readme":"\n# NestJS Messaging Module\n\nThis is an npm package for managing messaging in NestJS applications. It provides a way to configure messaging options and send messages from different services in your NestJS application.\n\n\n## Installation\n\n\nYou can install this package using npm or yarn:\n\n```bash\nnpm install @aiondigital/messaging-queues\n# or\nyarn add @aiondigital/messaging-queues\n```\n    \n## Usage/Examples\n\nTo configure the module globally, you can use the `MessagingModule.forRootAsync` method. This allows you to set up the messaging options for your application.\n\n```\nimport { MessagingModule } from '@aiondigital/messaging-queues';\nimport { ConfigurationService } from './configuration.service';\n\n@Module({\n  imports: [CommonModule],\n  imports: [\n    MessagingModule.forRootAsync({\n      useFactory: (_config: ConfigurationService) => {\n        return _config.MESSAGING_OPTIONS;\n      },\n      inject: [ConfigurationService],\n    }),\n  ],\n})\nexport class YourModule {}\n\n```\nThe `MESSAGING_OPTIONS` object should have the following fields:\n\n- expirationSeconds (optional): A number specifying message expiration time.\n- deadLetterExchange: The name of the dead-letter exchange.\n- deadLetterQueue: The name of the dead-letter queue.\n- brokerType: A value representing the broker type (e.g., \"redis\" or \"rabbitmq\").\n- rabbitmq (optional): Additional configuration for RabbitMQ, if brokerType is set to \"rabbitmq\".\n- redis (optional): Additional configuration for Redis, if brokerType is set to \"redis\".\n\n## Sending Messages\nYou can send messages from different services in your NestJS application using the MessagingService. First, you need to register a queue:\n\n```\nimport { MessagingModule } from '@aiondigital/messaging-queues';\n\n@Module({\n  imports: [MessagingModule.registerQueue({\n    name: ROUTING_KEYS.ADD_AUDIT_LOG,\n    exchangeName: EXCHANGE.AUDIT,\n  })],\n})\nexport class YourModule {}\n\n```\n\nThen, in your service, you can use the `MessagingService` to send messages:\n\n```\nimport { Injectable } from '@nestjs/common';\nimport { MessagingService } from '@aiondigital/messaging-queues';\n\n@Injectable()\nexport class YourService {\n  constructor(private readonly messagingService: MessagingService) {}\n\n  sendLogs(input) {\n    this.messagingService.sendMessage(ROUTING_KEYS.ADD_AUDIT_LOG, input);\n  }\n}\n\n```\n\nThat's it! You've now set up global configuration for the messaging module and can use the `MessagingService` to send messages from your NestJS services.\n\n## Message Processing\n\n### Class-Level Decorator\nAt the class level, you can use the @Processor decorator to specify which routing key this class will be responsible for processing. Here's how you can use it:\n\n```\nimport { Processor } from '@aiondigital/messaging-queues';\n\n@Processor(ROUTING_KEYS.ADD_AUDIT_LOG)\nexport class YourMessageProcessor {\n  // Your message processing methods go here\n}\n\n```\n\n### Function-Level Decorator\n\nFor individual message processing methods, you can use the `@Process` decorator to specify the details of the message processing. Here's how you can use it:\n\n```\nimport { Process } from '@aiondigital/messaging-queues';\nimport { CreateAuditLogInput } from './create-audit-log.dto';\n\n@Process({\n  name: '', // Give it a unique name\n  exchangeName: EXCHANGE.AUDIT,\n  routingKey: ROUTING_KEYS.ADD_AUDIT_LOG,\n})\nasync auditlog(data: CreateAuditLogInput, done: AckCallback) {\n  // Your message processing logic here\n  try {\n    const audit = await this.auditService.create(data, ['id']);\n    return audit;\n  } catch (error) {\n    this.#logger.error(`Failed to add audit log: [${JSON.stringify(data)}]`);\n    this.#logger.error(error);\n    done(error);\n  }\n}\n```\n\nYou should place the `@Process` decorator on methods that will process messages with a specific routing key. You can have multiple methods with different routing keys within the same class.\n\nRemember to replace the placeholders (`ROUTING_KEYS.ADD_AUDIT_LOG`, `EXCHANGE.AUDIT`, etc.)` with the actual values from your application.\n\nNow, the `YourMessageProcessor` class will process messages with the routing key specified in the `@Processor` decorator, and the `auditlog` method will handle messages with the routing key specified in the `@Process` decorator.\n\n\n## License\n\nThis package is released under the [MIT License](https://choosealicense.com/licenses/mit/) \n\n","readmeFilename":"readme.md","homepage":"https://github.com/wjamilaion/rubix-messaging-queues#readme","repository":{"type":"git","url":"git+https://github.com/wjamilaion/rubix-messaging-queues.git"},"bugs":{"url":"https://github.com/wjamilaion/rubix-messaging-queues/issues"}}