gistfile1.txt

var nsq = require('nsqjs');                                                                                                                                                                                                                   
                                                                                                                                                                                                                                              
function populate(done) {                                                                                                                                                                                                                     
    var w = new nsq.Writer('10.0.0.101', 4150);                                                                                                                                                                                               
    w.connect();                                                                                                                                                                                                                              
    w.on('ready', function() {                                                                                                                                                                                                                
        function publish(n, max) {                                                                                                                                                                                                            
            if (n < max) {                                                                                                                                                                                                                    
                console.log('populating message %s', n);                                                                                                                                                                                      
                w.publish('test_topic', 'hello ' + n);                                                                                                                                                                                        
                return publish(n + 1, max);                                                                                                                                                                                                   
            }                                                                                                                                                                                                                                 
            done();                                                                                                                                                                                                                           
        }                                                                                                                                                                                                                                     
        publish(0, 10);                                                                                                                                                                                                                       
    });                                                                                                                                                                                                                                       
}                                                                                                                                                                                                                                             
                                                                                                                                                                                                                                              
function read() {                                                                                                                                                                                                                             
    var r = new nsq.Reader('test_topic', 'churn_n_burn', {                                                                                                                                                                                    
        lookupdHTTPAddresses: '10.0.0.101:4161',                                                                                                                                                                                              
        maxInFlight: 2                                                                                                                                                                                                                        
    });                                                                                                                                                                                                                                       
    r.on('message', function(msg) {                                                                                                                                                                                                           
        console.log(msg.body.toString());                                                                                                                                                                                                     
        setTimeout(function() { msg.finish(); }, 5000);                                                                                                                                                                                       
    });                                                                                                                                                                                                                                       
    r.connect();                                                                                                                                                                                                                              
}                                                                                                                                                                                                                                             
                                                                                                                                                                                                                                              
//populate(read);                                                                                                                                                                                                                             
read();