natsio-example.json
Nats example
This is an example for node-red-contrib-natsio nodes.
You'll need to use a gnatsd server.
[{"id":"d427be3c.5019c8","type":"tab","label":"pub/sub","disabled":false,"info":""},{"id":"db0a3d07.891648","type":"tab","label":"request/reply","disabled":false,"info":""},{"id":"563b7678.bff208","type":"tab","label":"req/rep with timeout","disabled":false,"info":""},{"id":"bd192ef9.1d07a","type":"tab","label":"queue","disabled":false,"info":""},{"id":"84965814.4b71a","type":"ui_base","theme":{"name":"theme-light","lightTheme":{"default":"#0094CE","baseColor":"#0094CE","baseFont":"-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Oxygen-Sans,Ubuntu,Cantarell,Helvetica Neue,sans-serif","edited":true,"reset":false},"darkTheme":{"default":"#097479","baseColor":"#097479","baseFont":"-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Oxygen-Sans,Ubuntu,Cantarell,Helvetica Neue,sans-serif","edited":false},"customTheme":{"name":"Untitled Theme 1","default":"#4B7930","baseColor":"#4B7930","baseFont":"-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Oxygen-Sans,Ubuntu,Cantarell,Helvetica Neue,sans-serif"},"themeState":{"base-color":{"default":"#0094CE","value":"#0094CE","edited":false},"page-titlebar-backgroundColor":{"value":"#0094CE","edited":false},"page-backgroundColor":{"value":"#fafafa","edited":false},"page-sidebar-backgroundColor":{"value":"#ffffff","edited":false},"group-textColor":{"value":"#1bbfff","edited":false},"group-borderColor":{"value":"#ffffff","edited":false},"group-backgroundColor":{"value":"#ffffff","edited":false},"widget-textColor":{"value":"#111111","edited":false},"widget-backgroundColor":{"value":"#0094ce","edited":false},"widget-borderColor":{"value":"#ffffff","edited":false},"base-font":{"value":"-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Oxygen-Sans,Ubuntu,Cantarell,Helvetica Neue,sans-serif"}}},"site":{"name":"Node-RED Dashboard","hideToolbar":"false","allowSwipe":"false","dateFormat":"DD/MM/YYYY","sizes":{"sx":48,"sy":48,"gx":6,"gy":6,"cx":6,"cy":6,"px":0,"py":0}}},{"id":"cc875b4f.8fcc8","type":"natsio-server","z":"","name":"Broker","host":"localhost","port":"4222"},{"id":"a7bd05d8.3f6a68","type":"inject","z":"d427be3c.5019c8","name":"","topic":"foo","payload":"hola","payloadType":"str","repeat":"","crontab":"","once":false,"x":217,"y":98,"wires":[["3cb0d50f.fa881a"]]},{"id":"b9316e6a.a0c408","type":"debug","z":"d427be3c.5019c8","name":"","active":true,"console":"false","complete":"true","x":407,"y":158,"wires":[]},{"id":"e820540e.0adfc","type":"natsio-sub","z":"d427be3c.5019c8","server":"cc875b4f.8fcc8","subject":"foo","maxWanted":"","queue":"","x":217,"y":158,"wires":[["b9316e6a.a0c408"]]},{"id":"3cb0d50f.fa881a","type":"natsio-pub","z":"d427be3c.5019c8","server":"cc875b4f.8fcc8","subject":"","message":"","x":377,"y":98,"wires":[]},{"id":"6bf748df.82606","type":"inject","z":"db0a3d07.891648","name":"","topic":"help","payload":"hola","payloadType":"str","repeat":"","crontab":"","once":false,"x":203,"y":117,"wires":[["a22970a4.2f33b8"]]},{"id":"d3673484.328c9","type":"debug","z":"db0a3d07.891648","name":"","active":true,"console":"false","complete":"true","x":553,"y":117,"wires":[]},{"id":"381e6668.c42ea2","type":"inject","z":"db0a3d07.891648","name":"","topic":"help","payload":"Hi","payloadType":"str","repeat":"","crontab":"","once":false,"x":193,"y":157,"wires":[["a22970a4.2f33b8"]]},{"id":"a22970a4.2f33b8","type":"nats-request","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"","maxReplies":"","timeout":"","x":378.5,"y":116,"wires":[["d3673484.328c9"]]},{"id":"640412f3.2c073c","type":"comment","z":"db0a3d07.891648","name":"Request client","info":"","x":132.5,"y":74,"wires":[]},{"id":"7bd72077.2d0588","type":"natsio-pub","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"","message":"","x":528,"y":257,"wires":[]},{"id":"478a5f1c.010ac","type":"function","z":"db0a3d07.891648","name":"","func":"if(!msg.replyTo){\n return null\n}\n\nlet p = msg.payload\nif(p == 'hola'){\n p = 'Qué tal?'\n} else {\n p = 'I can help!'\n}\n\nmsg.payload = p\nreturn msg;","outputs":1,"noerr":0,"x":338,"y":257,"wires":[["7bd72077.2d0588"]]},{"id":"fe20a00c.869728","type":"natsio-sub","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"help","maxWanted":"","queue":"","x":188,"y":257,"wires":[["478a5f1c.010ac","a8c7c40c.cd7928"]]},{"id":"cec56360.ccbb38","type":"comment","z":"db0a3d07.891648","name":"Replyer client","info":"","x":135.5,"y":212,"wires":[]},{"id":"a8c7c40c.cd7928","type":"debug","z":"db0a3d07.891648","name":"","active":true,"console":"false","complete":"true","x":338,"y":297,"wires":[]},{"id":"88a6e013.8b4fd","type":"comment","z":"d427be3c.5019c8","name":"Simple pub/sub","info":"Automaticallly unsubscription after Nmessages","x":122.5,"y":49,"wires":[]},{"id":"96bc4f8a.768e7","type":"inject","z":"d427be3c.5019c8","name":"","topic":"bar","payload":"Hallo","payloadType":"str","repeat":"","crontab":"","once":false,"x":237,"y":278,"wires":[["66297df5.601374"]]},{"id":"266ee863.65acb","type":"debug","z":"d427be3c.5019c8","name":"","active":true,"console":"false","complete":"true","x":427,"y":338,"wires":[]},{"id":"5d7850a5.8a11a8","type":"natsio-sub","z":"d427be3c.5019c8","server":"cc875b4f.8fcc8","subject":"bar","maxWanted":"2","queue":"","x":237,"y":338,"wires":[["266ee863.65acb"]]},{"id":"66297df5.601374","type":"natsio-pub","z":"d427be3c.5019c8","server":"cc875b4f.8fcc8","subject":"","message":"","x":397,"y":278,"wires":[]},{"id":"76a3f4f8.b17d9c","type":"comment","z":"d427be3c.5019c8","name":"With a maximun of messages","info":"Automaticallly unsubscription after Nmessages","x":182.5,"y":229,"wires":[]},{"id":"3c92794f.45e96e","type":"natsio-pub","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"","message":"","x":560,"y":600,"wires":[]},{"id":"6d71b825.287c3","type":"function","z":"db0a3d07.891648","name":"","func":"if(!msg.replyTo){\n return null\n}\n\nlet p = msg.payload\nif(p == 'hola'){\n p = 'what\\'s up?'\n} else {\n p = 'I can help!'\n}\n\nmsg.payload = p\nreturn msg;","outputs":1,"noerr":0,"x":370,"y":600,"wires":[["3c92794f.45e96e"]]},{"id":"a97628e0.65f08","type":"natsio-sub","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"ayuda","maxWanted":"2","queue":"","x":220,"y":600,"wires":[["6d71b825.287c3","50fc503f.c0984","df8e9157.9847e8","51ad928d.144f4c"]]},{"id":"50fc503f.c0984","type":"debug","z":"db0a3d07.891648","name":"","active":false,"console":"false","complete":"true","x":370,"y":560,"wires":[]},{"id":"d74e8968.d0a1f8","type":"inject","z":"db0a3d07.891648","name":"","topic":"ayuda","payload":"hola","payloadType":"str","repeat":"","crontab":"","once":false,"x":200,"y":500,"wires":[["f04b68b3.ace208"]]},{"id":"ff6fb534.d08588","type":"debug","z":"db0a3d07.891648","name":"","active":true,"console":"false","complete":"true","x":550,"y":500,"wires":[]},{"id":"75fc9a8e.6ec63c","type":"inject","z":"db0a3d07.891648","name":"","topic":"ayuda","payload":"Hi","payloadType":"str","repeat":"","crontab":"","once":false,"x":200,"y":540,"wires":[["f04b68b3.ace208"]]},{"id":"f04b68b3.ace208","type":"nats-request","z":"db0a3d07.891648","server":"cc875b4f.8fcc8","subject":"","maxReplies":"2","timeout":"","x":375.5,"y":499,"wires":[["ff6fb534.d08588"]]},{"id":"de24c2e1.88f22","type":"comment","z":"db0a3d07.891648","name":"Request client","info":"","x":130,"y":460,"wires":[]},{"id":"df8e9157.9847e8","type":"function","z":"db0a3d07.891648","name":"","func":"if(!msg.replyTo){\n return null\n}\n\nlet p = msg.payload\nif(p == 'hola'){\n p = 'Qué tal?'\n} else {\n p = 'Ich kan helfen!'\n}\n\nmsg.payload = p\nreturn msg;","outputs":1,"noerr":0,"x":370,"y":640,"wires":[["3c92794f.45e96e"]]},{"id":"51ad928d.144f4c","type":"function","z":"db0a3d07.891648","name":"","func":"if(!msg.replyTo){\n return null\n}\n\nlet p = msg.payload\nif(p == 'hola'){\n p = 'Wer bist du?'\n} else {\n p = 'Yo te ayudo!'\n}\n\nmsg.payload = p\nreturn msg;","outputs":1,"noerr":0,"x":370,"y":680,"wires":[["3c92794f.45e96e"]]},{"id":"a9514de0.2b7d68","type":"natsio-sub","z":"563b7678.bff208","server":"cc875b4f.8fcc8","subject":"helfen","maxWanted":"","queue":"","x":197,"y":175,"wires":[["5a473840.fd1f08"]]},{"id":"5a473840.fd1f08","type":"debug","z":"563b7678.bff208","name":"","active":true,"console":"false","complete":"true","x":347,"y":135,"wires":[]},{"id":"1f80aba.1a4f754","type":"inject","z":"563b7678.bff208","name":"","topic":"helfen","payload":"hola","payloadType":"str","repeat":"","crontab":"","once":false,"x":177,"y":75,"wires":[["a54fa20.5954a6"]]},{"id":"89ac3b12.6ae9e","type":"debug","z":"563b7678.bff208","name":"","active":true,"console":"false","complete":"true","x":508,"y":74,"wires":[]},{"id":"1b1210d8.41af17","type":"inject","z":"563b7678.bff208","name":"","topic":"helfen","payload":"Hi","payloadType":"str","repeat":"","crontab":"","once":false,"x":177,"y":115,"wires":[["a54fa20.5954a6"]]},{"id":"a54fa20.5954a6","type":"nats-request","z":"563b7678.bff208","server":"cc875b4f.8fcc8","subject":"","maxReplies":"","timeout":"3000","x":352.5,"y":74,"wires":[["89ac3b12.6ae9e"]]},{"id":"5a7e433f.af702c","type":"comment","z":"563b7678.bff208","name":"Request with timeout","info":"","x":137,"y":35,"wires":[]},{"id":"982d25ee.a31ed","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G1","x":199.5,"y":246,"wires":[["68899001.b4b7e"]]},{"id":"93578698.b2e168","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G1","x":200.5,"y":292,"wires":[["c10d4a6b.03fe1"]]},{"id":"f1795e41.195068","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G1","x":201.5,"y":340,"wires":[["59b2215f.18e87"]]},{"id":"68899001.b4b7e","type":"function","z":"bd192ef9.1d07a","name":"Node G1-1","func":"let p = msg.payload;\nmsg.payload = 'Node G1-1: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":367.5,"y":246,"wires":[["275b7ed3.44a7ea"]]},{"id":"c10d4a6b.03fe1","type":"function","z":"bd192ef9.1d07a","name":"Node G1-2","func":"let p = msg.payload;\nmsg.payload = 'Node G1-2: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":366.5,"y":292,"wires":[["275b7ed3.44a7ea"]]},{"id":"59b2215f.18e87","type":"function","z":"bd192ef9.1d07a","name":"Node G1-3","func":"let p = msg.payload;\nmsg.payload = 'Node G1-3: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":365.5,"y":340,"wires":[["275b7ed3.44a7ea"]]},{"id":"275b7ed3.44a7ea","type":"debug","z":"bd192ef9.1d07a","name":"","active":true,"console":"false","complete":"true","x":531.5,"y":292,"wires":[]},{"id":"89ec38b7.89cf7","type":"natsio-pub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"","message":"","x":377.5,"y":159,"wires":[]},{"id":"d849f023.75321","type":"inject","z":"bd192ef9.1d07a","name":"","topic":"foo.reply","payload":"Hi","payloadType":"str","repeat":"","crontab":"","once":false,"x":216.5,"y":159,"wires":[["89ec38b7.89cf7"]]},{"id":"fb0a8895.6c98b8","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G2","x":199,"y":432,"wires":[["9e534f37.018228"]]},{"id":"b3deec00.79c68","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G2","x":200,"y":478,"wires":[["abfd4320.4d62b"]]},{"id":"52fd11be.f65cc","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"G2","x":201,"y":526,"wires":[["b963ac58.3b8b2"]]},{"id":"9e534f37.018228","type":"function","z":"bd192ef9.1d07a","name":"Node G2-1","func":"let p = msg.payload;\nmsg.payload = 'Node G2-1: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":367,"y":432,"wires":[["9d2367e1.9109b8"]]},{"id":"abfd4320.4d62b","type":"function","z":"bd192ef9.1d07a","name":"Node G2-2","func":"let p = msg.payload;\nmsg.payload = 'Node G2-2: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":366,"y":478,"wires":[["9d2367e1.9109b8"]]},{"id":"b963ac58.3b8b2","type":"function","z":"bd192ef9.1d07a","name":"Node G2-3","func":"let p = msg.payload;\nmsg.payload = 'Node G2-3: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":365,"y":526,"wires":[["9d2367e1.9109b8"]]},{"id":"9d2367e1.9109b8","type":"debug","z":"bd192ef9.1d07a","name":"","active":true,"console":"false","complete":"true","x":528,"y":478,"wires":[]},{"id":"98764d97.fcc48","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"","x":195,"y":626,"wires":[["5cdfa5d0.90b084"]]},{"id":"a325a894.63521","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"","x":196,"y":672,"wires":[["a030c6e3.61dfc"]]},{"id":"c6a3a20a.765ae","type":"natsio-sub","z":"bd192ef9.1d07a","server":"cc875b4f.8fcc8","subject":"foo.reply","maxWanted":"","queue":"","x":197,"y":720,"wires":[["9d9e915b.d3fd8"]]},{"id":"5cdfa5d0.90b084","type":"function","z":"bd192ef9.1d07a","name":"Node G3-1","func":"let p = msg.payload;\nmsg.payload = 'Node G3-1: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":363,"y":626,"wires":[["8b7ff4ac.5e8c18"]]},{"id":"a030c6e3.61dfc","type":"function","z":"bd192ef9.1d07a","name":"Node G3-2","func":"let p = msg.payload;\nmsg.payload = 'Node G3-2: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":362,"y":672,"wires":[["8b7ff4ac.5e8c18"]]},{"id":"9d9e915b.d3fd8","type":"function","z":"bd192ef9.1d07a","name":"Node G3-3","func":"let p = msg.payload;\nmsg.payload = 'Node G3-3: '+p;\nreturn msg;","outputs":1,"noerr":0,"x":361,"y":720,"wires":[["8b7ff4ac.5e8c18"]]},{"id":"8b7ff4ac.5e8c18","type":"debug","z":"bd192ef9.1d07a","name":"","active":true,"console":"false","complete":"true","x":524,"y":672,"wires":[]}]
