издатель шаблон subscribber в nodejs код sampel не woring с вне setinterval

Question

Я пытаюсь реализовать паб/к югу, как показано ниже

publisher.js

var zmq = require('zmq'); 
var pub = zmq.socket('pub'); 

pub.bindSync('tcp://127.0.0.1:5555'); 

pub.send('pub msg'); 
/* 
setInterval(function(){ 
    console.log("sending message") 

},500);*/ 

subscriber.js

var zmq = require('zmq'); 
var sub = zmq.socket('sub'); 
sub.connect('tcp://127.0.0.1:5555'); 

sub.subscribe(''); //herein lies the question 

sub.on('message',function(msg){ 
    console.log('Received msg:',msg); 
}) 

вышеуказанный абонент получит сообщение только в том случае, если pub.send('pub msg'); находится внутри setInterval не уверен в моем понимании

Я не хочу использовать setInterval, а я должен послать сообщение, как только он прибыл

Пожалуйста сказать, как я могу сделать это с помощью паб/суб только я предполагаю, что есть некоторые базовые знания отсутствуют, пожалуйста, помогите

в nodejs код я пытаюсь используя маршрут имеет

router.post('/putMsgIn0MQ', function (req, res, next) { 
    pushData(JSON.stringify(req.body)) 
}) 

var pushData = function(dataToPush) { 
    var zmqSocket = zmq.socket('pub') 
     var zmqPortPart = 'tcp://127.0.0.1:5555' 
     zmqSocket.bind(zmqPortPart); 
     zmqSocket.send(dataToPush); 

} 

подписчик

var sub = zmq.socket('sub'); 
       sub.connect('tcp://127.0.0.1:5555'); 
       sub.subscribe(''); //herein lies the question 
       console.log('Received msg:'); 
       sub.on('message',function(msg){ 
         console.log('Received msg:'); 
         console.log(msg.toString()) 
         var jsonPayload = msg.toString(); 
         processData(jsonPayload, zmqPortObj.name); 
       }) 

Answer 1

на основе этого кода, от их дел cumentaiton:

// pubber.js 
var zmq = require('zmq') 
    , sock = zmq.socket('pub'); 

    sock.bindSync('tcp://127.0.0.1:3000'); 
console.log('Publisher bound to port 3000'); 

setInterval(function(){ 
    console.log('sending a multipart message envelope'); 
    sock.send(['kitty cats', 'meow!']); 
}, 500); 

Кажется, что setInterval только функция полезности :)

Что мешает, что вы запустите его вручную?

Так, например, мнимое контроллер:

exports.animals= { 
    getCat: function (request, response) { 

    var animal = request.payload.catStuff; 

    //process the animal object 
    //and manually fire the message like: 


sock.send(['kitty cats', 'meow!']); 

...