medium story NATS-streaming with node js

connect.js

var nats = require('node-nats-streaming').connect('fissionMQTrigger', 'web-crawler-'+Math.random().toString(11).replace('0.', ''), process.env.NATS_CONNECTION)
nats.on('error', function(err) {
	console.log(err);
})

structured-data.js

nats.publish('profile.enrichment.input', JSON.stringify({
          network: 'lin',
          service: 'lin-scrapper',
          id: profileId,
          content: doc.profile
        }))
      }