vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/pubsub/server.js

   1 'use strict';
   2
   3 var freemem = require('os').freemem;
   4 var codec = require('../codec');
   5
   6 var id = Math.random();
   7 var recv = 0;
   8
   9 var sub = require('redis').createClient()
  10         .on('ready', function() {
  11                 this.subscribe('timeline');
  12         })
  13         .on('message', function(channel, message) {
  14                 var self = this;
  15                 if (message) {
  16                         message = codec.decode(message);
  17                         ++recv;
  18                 }
  19         });
  20
  21 setInterval(function() {
  22         console.error('id', id, 'received', recv, 'free', freemem());
  23 }, 2000);