{"_id":"@amicopo/pipelinemessaging","name":"@amicopo/pipelinemessaging","dist-tags":{"latest":"0.0.1"},"versions":{"0.0.1":{"name":"@amicopo/pipelinemessaging","version":"0.0.1","description":"A library which implements amqp messaging withing a microservice architecture","main":"index.js","type":"module","scripts":{"test":"echo \"Error: no test specified\" && exit 1"},"keywords":["amqp","messaging","thesisfair"],"author":{"name":"Quinten Coltof"},"license":"ISC","dependencies":{"amqplib":"^0.8.0","debug":"^4.3.4"},"gitHead":"650637a7015a2d2f608f0aefe3e8a58a238011fc","_id":"@amicopo/pipelinemessaging@0.0.1","_nodeVersion":"18.16.1","_npmVersion":"9.5.1","dist":{"integrity":"sha512-sgEANRZS72hGiVBbarsW7YLO5OvvS/2/tg2pc3NIAouxgsqXzHQzoHYXfd5WRdKKQbLqRi8nioH++Vu/aCd58Q==","shasum":"436255c271d89645fd3fe31f1f7b8d85b3036ffe","tarball":"https://registry.npmjs.org/@amicopo/pipelinemessaging/-/pipelinemessaging-0.0.1.tgz","fileCount":5,"unpackedSize":21493,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQC9trGuJ18MOPg9FM2YZ+x3sKWhyf9Wkm6USiKomH9hgAIgfZwhjlm1XoYjTTFJJDHYsbOq0hCnC1WxojS6dXtOJOU="}]},"_npmUser":{"name":"amicopo","email":"quintencoltof1@gmail.com"},"directories":{},"maintainers":[{"name":"amicopo","email":"quintencoltof1@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/pipelinemessaging_0.0.1_1687459639583_0.25768547770498396"},"_hasShrinkwrap":false}},"time":{"created":"2023-06-22T18:47:19.448Z","0.0.1":"2023-06-22T18:47:19.833Z","modified":"2023-06-22T18:47:20.162Z"},"maintainers":[{"name":"amicopo","email":"quintencoltof1@gmail.com"}],"description":"A library which implements amqp messaging withing a microservice architecture","keywords":["amqp","messaging","thesisfair"],"author":{"name":"Quinten Coltof"},"license":"ISC","readme":"# Example config\n```js\nconst exampleConfigPlus = [ // x + 2 - 10\n  {\n    endpoint: 'amqp://rabbitmq',\n    queues: {\n      plusCalculation: {\n        steps: {\n          0: {\n            fnName: 'plus',\n            extraArgs: [2],\n            outId: 0,\n            outQueue: 'minCalculation'\n          },\n        }\n      }\n    }\n  }\n]\n\nconst exampleConfigMin = [ // x + 2 - 10\n  {\n    endpoint: 'amqp://rabbitmq',\n    queues: {\n      minCalculation: {\n        steps: {\n          1: {\n            fnName: 'min',\n            extraArgs: [10],\n            outId: 0,\n            outQueue: '!gateway'\n          },\n        }\n      }\n    }\n  }\n]\n\nconst exampleConfigGateway = [\n  {\n    endpoint: 'amqp://rabbitmq',\n    queues: {\n      '!gateway': {\n        steps: {\n          2: {\n            fnName: 'reply',\n          }\n        }\n      }\n    }\n  }\n]\n\nconst exampleReplyGateway = [\n  {\n    endpoint: 'amqp://rabbitmq',\n    queues: {\n      '!gateway': {\n        steps: {\n          0: {\n            fnName: 'identity',\n            extraArgs: [],\n            outId: 0,\n            outQueue: '!gateway'\n          },\n          1: {\n            fnName: 'reply',\n            extraArgs: [],\n          },\n        }\n      }\n    }\n  }\n];\n```\n\n# Example data being send between everyone\n```js\nconst exampleData = {\n  reqId: 0,\n  step: 1,\n  input: 10, // Whatever type of object\n}\n```\n","readmeFilename":"Readme.md"}