You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
33 lines
678 B
33 lines
678 B
var kestrel = require('../');
|
|
|
|
|
|
//create our producer
|
|
var producer = new kestrel.kestrelProducer( 'test', {
|
|
connectionType: kestrel.connectionType.FAILOVER,
|
|
servers: ['127.0.0.1:22133']
|
|
});
|
|
|
|
|
|
//capture all 'stored' events
|
|
producer.on('stored', function(stored){
|
|
console.log('Stored: ' + stored);
|
|
});
|
|
|
|
|
|
//lets input some data
|
|
var interval = setInterval( function(){
|
|
producer.send( (new Date().getTime()) + ' - New Message', function(err){
|
|
if(err){
|
|
console.log("ERR",err);
|
|
} else {
|
|
console.log("STORED");
|
|
}
|
|
} );
|
|
}, 100);
|
|
|
|
|
|
//close connection
|
|
setTimeout( function(){
|
|
clearInterval(interval);
|
|
producer.close();
|
|
}, 6000);
|