{"_id":"@agena3000/rabbitmq-njs","_rev":"5-44f4f14d2c87081b2318eb7abbc2e1eb","name":"@agena3000/rabbitmq-njs","dist-tags":{"latest":"1.0.4"},"versions":{"1.0.0":{"name":"@agena3000/rabbitmq-njs","version":"1.0.0","description":"Provide functions for RabbitMQ processes based on amqplib connection","main":"index.js","scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"repository":{"type":"git","url":"https://gitlab.agena3000.com/common/rabbitmq-njs"},"keywords":["RabbitMQ","AMQP","amqplib"],"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","gitHead":"d7d436b6916715b313be28ff41e0b679ca23cb30","_id":"@agena3000/rabbitmq-njs@1.0.0","_nodeVersion":"8.17.0","_npmVersion":"6.13.4","dist":{"integrity":"sha512-2wO+52fm63gKDFxpNHiVcAt/AtjY4cw7W865/N6fTfsIxcnnU7pv60w+3d54luWW1KWfg8YL1ebGeu4Ng+YTPA==","shasum":"0ffcebc3117e1f6a844e833f8488492009f52609","tarball":"https://registry.npmjs.org/@agena3000/rabbitmq-njs/-/rabbitmq-njs-1.0.0.tgz","fileCount":3,"unpackedSize":1253,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeeJ/fCRA9TVsSAnZWagAA/DkQAJclFMv3I18TXJ8ocKvx\nAcgn3MtN1PJQo+C7gyLe3USsI0V7fO0CvZRUFpmZYcEUghdtGtdRt9fE36aG\nOMLkX9zDseJm/Nxk0rW7EB8AezuYeLa0Fek0fgA+r5rtBt57J2ZJMzPcd1m/\nHRbeMq/h09F9OrtZS72G1QCTNhnI0QP3oHXVQMAnaXl1ASWk76dluGCGx8bN\n6htLC1yGN7h/itPy5YSaqSaXPSNT8U9zTGxOxm4yz81PwyVVp2AL5CfxW4I0\n6MRmdManco2eL/74s043Z/PmY56jkpljfXSBG8pLC+/5Cska/CwdPh9cMc4y\ntgS3IYEOB8wJwx3qk64axjXSpAkcedaD7q4gtZwcrY8tS4HSprI2QDCrshBG\nUlS7ASJQT4qE2t8FIgZlfTNY/Vem06W8ZrXNYyh0iBV5HVsISuIDFL77lxUT\naB18xZtP3MJMd8yUuG58UnHqbFYmTO1cyRqU9qRoSnEaGYLmi05gLTqc7jEn\nyXv0oOh8CjGrztlo1vDR1FKFJ75pJLTVLbfF3O07jXmVeM6iFJLHLJoiRJBg\noTMEfWMFPNGCprE0OJolozrWdoQRx+c2DIFnNpETKepQLjh2vgU8m6YEAJ2/\nnwa0QnV0Ws8OdJLkCkTr/ZZ9uTXcoCkpFxEtcEI7xe1Zo/ebtoWsYS8GV9NK\nXFJY\r\n=FuvY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDTLpUKx5zFttX742rPfzQ7O05oxln7QhLPPnVvu9b5+wIhAM6PzIFzvQyVF6z5eZgTpANm2+Irn//0ZUqHz2Uvo5xf"}]},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"_npmUser":{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rabbitmq-njs_1.0.0_1584963550576_0.43933458285902005"},"_hasShrinkwrap":false},"1.0.1":{"name":"@agena3000/rabbitmq-njs","version":"1.0.1","description":"Provide functions for RabbitMQ processes based on amqplib connection","main":"index.js","scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"repository":{"type":"git","url":"https://gitlab.agena3000.com/common/rabbitmq-njs"},"keywords":["RabbitMQ","AMQP","amqplib"],"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","gitHead":"6b08b6f89b380a8abb8dbd2dceb781cde268a05b","_id":"@agena3000/rabbitmq-njs@1.0.1","_nodeVersion":"8.17.0","_npmVersion":"6.13.4","dist":{"integrity":"sha512-E+rCQFTGj7YzhMm5OzhayUI1r4gIajpY/2PPXvVwN+1bWrlEUZBed0KBVBX4qOPKK3rx3UVqN1GUDm21ojTFIA==","shasum":"0db7ae4d04fa1fbeecd79e5bbae317cdc7a4ab19","tarball":"https://registry.npmjs.org/@agena3000/rabbitmq-njs/-/rabbitmq-njs-1.0.1.tgz","fileCount":3,"unpackedSize":1868,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeeLfnCRA9TVsSAnZWagAAvuMP/jbsvkkAPKwa+qRmFxdL\nV8qaXig0kOY9Gv3im8oWlS8e62kw64+AzZamUHY9gxhg6oTTxaLYWL89T/c3\nVtsP+kk7WO146dmbx6RfrEKSJu0dB/zMoiSEt2pWJY4PwvJ+eo8dIzXj5JN1\nnQXM0ovd7AogR+D3vgRvJ9kKJhVh5lz3xbPzKEdwFkjLrefYEdnSDeJY3Mcz\nOJLPapg0TxRYmktwDc51r/4sTi0rhf3Ch9TDKRsqSceeSmSMawPHi7datUB7\nlcv2TEo1o0QLBIqCGTizoFAVhpia8A2eXCqgNF1FGgF5KCjgPh3QOSuraV4m\n6eXZVS8KhlT6Bfln4Gk6HsexewMSRF6Wnp/7t5TukpvPlFrJER4/RWtBLHGF\n3MEw+Zig/EusR9RiY3rPaJrT2BiOFlzLu6Uu8qJFWgFlQgEWz7zedVqQo87c\nrtbNC69P/voUL9xILH92Lfuobm/cBMbBM3ao940zzgqM+E1PeS/8QyA9kRhU\ns5yz1J/4hoUcIY7ZwYykW3dvtFCddnxOpb13E5Ky3pfnwRymdi4F6QCasHTr\nJquaoeG/+Wpwi1ts8XHa/C1xNGRbHe/EsfEqaxqfNu+38SEcO5V/e1fq1BEQ\nBc1m2xXeHERkAcupuQ4hEM9xtB/c8XJDKRaCh7WlbHQ5+qYECldWtAZn4lKN\nXAnc\r\n=4hUr\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCwfhIuphRwmU4ftfD72BgS1bEssS+SyImLpvotk+trWgIgdBuugygzILEunEj3C2jwBdrIbr2zMc5NHToop1VRLLg="}]},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"_npmUser":{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rabbitmq-njs_1.0.1_1584969703116_0.07766676541368955"},"_hasShrinkwrap":false},"1.0.2":{"name":"@agena3000/rabbitmq-njs","version":"1.0.2","description":"Provide functions for RabbitMQ processes based on amqplib connection","main":"index.js","scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"repository":{"type":"git","url":"https://gitlab.agena3000.com/common/rabbitmq-njs"},"keywords":["RabbitMQ","AMQP","amqplib"],"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","gitHead":"f5e99b18104392d5ba96dd6282a441d3e0b6cf84","_id":"@agena3000/rabbitmq-njs@1.0.2","_nodeVersion":"8.17.0","_npmVersion":"6.13.4","dist":{"integrity":"sha512-ulhpDkZN5CqRL83CcLyI8BPFxQV9q531YgPHHXiOlBMiWLa1vojPW8cOREAsGIGsHuqGgFpSAfL1St3jWNBbEg==","shasum":"a4de1aa230bebb35be32e052beba4f68e4191c8c","tarball":"https://registry.npmjs.org/@agena3000/rabbitmq-njs/-/rabbitmq-njs-1.0.2.tgz","fileCount":3,"unpackedSize":1842,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeeLh2CRA9TVsSAnZWagAAiIMQAI4yW/bB1MV+geOkVUxg\n1Q11BdqLbpEMQw32yhIvX628luZvqkRdHuTq6SjRRpuIZdKWlUyjm+pGoZsy\nWkaiG9Hs+pUqc3s8syxv6uoiH3Zp/pnwCo1jclPL+Tv5ASrjH84QDqLDQuae\nem+4gxx+Tv0mOASiIXA9dO0Rd4/OIr9qqt6akWobvwW7tMGmZcxZImv/Wau4\nozn+7AewyrVEqv/AiduFo8AhrsNHGmr9Ks/Sv8Pcupv6TDyBTPHEyTX+2DhI\nrNX7/2jMlQ/n5DwEsRXulQv37L7MCtfOoQu+7Aqj15CYMmZh7Cy5GPdJtFJl\nthz2KCAnuvrBopQX6ZSNXGanT7LhP/uD2vZjeVfsltYyZQZYxCO22Q2AVird\nqVUojeC9KN9u2+HWZ8DAhTZfFCx0OcMzHC+b4U7kWLRR/HytTWh3d9pnuRp1\necmFHM5tSeBi+kh1SywmFPsBQCc/9FO1266yGo7j7XqpSWegcstJOj4zTHaH\n82o/2BKUMN5S8EJ3uTplnX7M9N6F0fJHw51r4BIKd2uW29OXGzmUTRkquVhr\nkag93GjmCC0uXDnDoAirggUuz35OIgN9kP/wZfmV9T4mzVs9xJuDd3pFWbJC\nVv7iI6lYmZ1InJ77nGwqoO7CYiTtdYn2LkT6l4Q+GaPxYMEbF930naMybGe7\nu6XL\r\n=F7x8\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIC/WqjptTRxbuv13l/NgFNMQ5lZrMTTX8XEQ1UxtDntjAiEAwL+/T70u0L8lMKLwKONGEwidHoP7H9jVP/6EKSOjpkg="}]},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"_npmUser":{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rabbitmq-njs_1.0.2_1584969846347_0.02349244774815218"},"_hasShrinkwrap":false},"1.0.3":{"name":"@agena3000/rabbitmq-njs","version":"1.0.3","description":"Provide functions for RabbitMQ processes based on amqplib connection","main":"index.js","scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"repository":{"type":"git","url":"https://gitlab.agena3000.com/common/rabbitmq-njs"},"keywords":["RabbitMQ","AMQP","amqplib"],"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","gitHead":"d43ec196642deeaafe696dc10bd33c2a0a74ea2b","_id":"@agena3000/rabbitmq-njs@1.0.3","_nodeVersion":"8.17.0","_npmVersion":"6.13.4","dist":{"integrity":"sha512-IUN462rjhBPRbZie6TEWQaiYqmGQpWu/gx/jt+m/RrCREKRpaD/ZvxnJlHgHq6Z2dsJfcR8RoeSqwQmblonL3A==","shasum":"abc6c06f894fec1a2c402cb70882eebe4db98ea9","tarball":"https://registry.npmjs.org/@agena3000/rabbitmq-njs/-/rabbitmq-njs-1.0.3.tgz","fileCount":3,"unpackedSize":1758,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeeLujCRA9TVsSAnZWagAA3+4P+wcdxC4Wd/dWz7BkkNFk\nxJ4pZjjCjNPd4ZaPvL6Hhmkbsngc2wKj2VSzAjn0Q/OWv67XoPI2nqLtpba5\nkTJqZHj7t57r6lyur8ydKZr/KfFwglX2HGS93TwrIHBNgK0E6CZ6r/E4Axe6\nU8yl1KvNKJgN9+YwHiLjO0HyVDFBfuEDnM78MlWyUs6AWiWuS14joBbNDsHH\niPjuK4RQrY5Z+5kyS1ev7tQ3WQw/JjoPw1UQTgeRcghx1VdWFFsJ26qscyqb\nMooXz7t3g8a1/ThiQL4q1rJqDSMUIMDuKuBmFbXhnR8fwgaAwL8SfB0I7zyI\nzjklh+rU7kL50Tt2p0q2Uy5vGzaA/VUBlX2M+gkNALOVqN85ZGfXI+CXNzoT\nIR5gOmEhEAs4eFEduC0+0/xu7KRlP9tD51GM6gsO6MI4/8Md3rk8Zr5ySkN1\ncKYdK+3UDzvl45dmPU828IwQ0sMCyzwFsDvSjWbOQQ5ncZFOOg42g++t5q5h\nfM4427S2q5hLzhExuFcMf75aXO6WYJKpLf9ieduVknfowvbSa4ianxp0saAw\ny/hrNdFhE1R4Ezqd1ket47OF8Bo2Rcdezm1/HiveGmpfkdmvySakKlDqJJ4P\nfU6ZbT6O4qQ4CrYa4krNwZx5UziguzbaeXxAkKVKtobE32AUPdDUYaXCHuAW\niAsr\r\n=LfTK\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCYFcxKmyXVq+q7OntFHWW4ls2pnvmfSLBso3QqA68ItwIhAKl28P/NoAIUa2kYbtY3mD4sxdmK00s9f1sXjQYo78v+"}]},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"_npmUser":{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rabbitmq-njs_1.0.3_1584970658245_0.4355884771701466"},"_hasShrinkwrap":false},"1.0.4":{"name":"@agena3000/rabbitmq-njs","version":"1.0.4","description":"Provide functions for RabbitMQ processes based on amqplib connection","main":"index.js","repository":{"type":"git","url":"git+https://github.com/agena3000/rabbitmq-njs.git"},"keywords":["RabbitMQ","AMQP","amqplib"],"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","dependencies":{"amqplib":"^0.5.5"},"gitHead":"2a193e95796d4a1c84a99871e50fed4dcd28a4f2","bugs":{"url":"https://github.com/agena3000/rabbitmq-njs/issues"},"homepage":"https://github.com/agena3000/rabbitmq-njs#readme","_id":"@agena3000/rabbitmq-njs@1.0.4","_nodeVersion":"8.17.0","_npmVersion":"6.13.4","dist":{"integrity":"sha512-jjz3DhfThho46jrdeqz79TuDhEpEV/Ggm3gez6J9jQIFp7g2M4O0zKRwYVu1yREBQ4jUr2dLLwLN0WYxBFux6w==","shasum":"1b52621b830927e7376617c4372038dac3678262","tarball":"https://registry.npmjs.org/@agena3000/rabbitmq-njs/-/rabbitmq-njs-1.0.4.tgz","fileCount":7,"unpackedSize":4826,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeefJECRA9TVsSAnZWagAAveQP/iuLP/rGgx45RK4LwXsB\n2r/50OlODrYMG407UNlA354A2KsmpBJy/WmPiPEwbYBwK08yT6UqhHp8+DS+\nWOaO+WxNGbC9wjiqdtwihmKYNz7yTF2zDjWJPnVi1yuOj1+MMDjjQbHoGhHo\nAb54A9jj3PDOYjgaZ1EFmOSfU0GQee6j0lF0w4uAOUWvgHao3DrLZZiFHkPc\nAmTPzjL3Jyar6eyx87RGwi/R1ER4rhcrlJFjFVIVQtivK20LrXzgiB5sPU5a\n59rYqlatNht77sF4ywsgXS7Z2ooO0/RZUlMJFlPXJDyRhyDrUzJG5KaRuD/v\na5dePueYt04rJwSsCbX9qg6/ZchMAr7vydW3lBFcmRMzDWIOImCeHY+pItOi\n6QE40AneKBWR16fXzK3fbnG+YtR5b+OYIDHvibTuc76usKtxS5NiAyHNcsPJ\n8hJNb3zR3m28n9HEj+l7gTFsgUYxqDrJxDaL880cgP8E8W113ofjQCra4JU3\n8qyITIXqHRGkstts8XcVEazgWTVJw9VjmEDfo8zf5XjT/LRJ7lfilsfqnsmE\nUdDgx3vJ00E6d6RcONBZpaL9rA/mFydvpqMeI+XcIFU4gZ6/U5KioRz6QR3z\nONYmaOdmysgAxJHWX5CyWmMADIKm9MxdIWub6yujvTwEGWxNuZl+7bEd+LkN\nek0l\r\n=I152\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGgKDrB5qkGy3sDeGN44Mu3fMyEmmIBwEumZe+p790BLAiEArF37/svZz+6eKgvmSprIjMInnCmMwRO49bFMzJVfSdM="}]},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"_npmUser":{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/rabbitmq-njs_1.0.4_1585050179643_0.7209660039237151"},"_hasShrinkwrap":false}},"time":{"created":"2020-03-23T11:39:10.337Z","1.0.0":"2020-03-23T11:39:10.725Z","modified":"2022-04-04T11:55:19.399Z","1.0.1":"2020-03-23T13:21:43.291Z","1.0.2":"2020-03-23T13:24:06.445Z","1.0.3":"2020-03-23T13:37:38.761Z","1.0.4":"2020-03-24T11:42:59.740Z"},"maintainers":[{"name":"teddy.graveleau","email":"teddy.graveleau@orange.fr"}],"description":"Provide functions for RabbitMQ processes based on amqplib connection","keywords":["RabbitMQ","AMQP","amqplib"],"repository":{"type":"git","url":"git+https://github.com/agena3000/rabbitmq-njs.git"},"author":{"name":"Teddy Graveleau","email":"teddy.graveleau@orange.fr"},"license":"ISC","readme":"# rabbitmq-njs\r\n\r\nProvide functions for RabbitMQ processes based on amqplib connection.\r\n\r\nhttps://www.npmjs.com/package/@agena3000/rabbitmq-njs\r\n\r\n# Usage\r\nImport the package.\r\n\r\n```\r\nnpm i @agena3000/rabbitmq-njs\r\n```\r\n\r\n```js\r\nvar a3rmq = require('@agena3000/rabbitmq-njs')\r\n```\r\n\r\n## Publisher\r\n```js\r\nvar queue = 'test-queue'\r\namqp\r\n    .connect(\"amqp://admin:admin@rabbitmq.host\")\r\n    .then(con => a3rmq\r\n    .publish(con, queue, \"message\")\r\n    )\r\n```\r\n\r\n## Consumer\r\n```js\r\nvar queue = 'test-queue'\r\namqp\r\n    .connect(\"amqp://admin:admin@rabbitmq.host\")\r\n    .then(con => a3rmq\r\n    .consume(con, queue, msg => {\r\n        console.log(msg.content.toString())\r\n    })\r\n    )\r\n```\r\n\r\n# RPC (Remote Procedure Call) : request / response\r\n## Server\r\n```js\r\nvar queue = 'rpc-queue'\r\na3rmq\r\n    .connect(\"amqp://admin:admin@docker.agena3000.com:50020\")\r\n    .then(con => a3rmq\r\n        .rpcServer(con, queue, msg => {\r\n            // Handle request function has to return a String\r\n            console.log(\"Received :\",msg.content.toString())\r\n            return Math.pow(parseInt(msg.content.toString()), 2).toString()\r\n        })\r\n    )\r\n```\r\n\r\n## Client\r\n```js\r\nvar queue = 'rpc-queue'\r\na3rmq\r\n    .connect(\"amqp://admin:admin@docker.agena3000.com:50020\")\r\n    .then(con => a3rmq\r\n        .rpcClient(con, queue, \"2\")\r\n        .then(res => {\r\n            // Handle response\r\n            console.log(\"Res : \", res.content.toString())\r\n        })\r\n    )\r\n```\r\n\r\n# About Agena3000\r\nhttps://www.agena3000.com","readmeFilename":"README.md","homepage":"https://github.com/agena3000/rabbitmq-njs#readme","bugs":{"url":"https://github.com/agena3000/rabbitmq-njs/issues"}}