client.js

var zmq = require('zeromq');

s = zmq.createSocket('push');
s.connect('tcp://127.0.0.1:15000');

while (true) { // ZOMG he did it again!
  s.send(new Buffer("test"));
}

node-zmqd.js

var zmq = require('zeromq'),
    util = require('util'),
    redis = require("redis"),
    client = redis.createClient();

s = zmq.createSocket('pull');

var count = 0;
var time = null;

s.bind('tcp://127.0.0.1:15000', function(err) {
    if (err) throw err;
    s.on('message', function(data) {
        client.lpush('q', data.toString());
        count++;
        if (count == 1) {
          time = new Date();
        }
        if ((count % 10000) === 0) {
          var t = new Date();
          console.log('T: ' + ((t-time)/1000));
          time = t;
        }
    });
    util.puts('Server is up ...');
});