zmq-publisher.js

zmq-publisher.js

const fs = require('fs'),
      zmq = require('/usr/local/lib/node_modules/zmq'),
      filename = 'pub.txt';


const pub = zmq.socket('pub');

//watch the change in the file.
//when you want to sned the message make change in pub.txt

fs.watch(filename,  function() {
    //message send to subscriber with cat
    pub.send( [ 'cat' , JSON.stringify({
       type: 'change',
       file: filename,
       time: Date.now()
    })
    ]);

    //message send to subscriber with dog
    setTimeout( function () {
          pub.send(['dog' ,JSON.stringify({
                                   type: 'change',
                                   file: filename,
                                   time: Date.now()
                                 })
          ]);
        } , 10000)
});

pub.bind('tcp://*:3000', function() {
    console.log("Publisher listening to port 3000");
});