ØMQ bindings for node.js.
Install zmq package first.
$ npm install zmq
producer.js:
var zmq = require('zmq')
, sock = zmq.socket('push');
sock.bindSync('tcp://127.0.0.1:3000');
console.log('Producer bound to port 3000');
setInterval(function(){
console.log('sending work');
sock.send('some work');
}, 500);
worker.js:
var zmq = require('zmq')
, sock = zmq.socket('pull');
sock.connect('tcp://127.0.0.1:3000');
console.log('Worker connected to port 3000');
sock.on('message', function(msg){
console.log('work: %s', msg.toString());
});
Install dev deps:
$ npm install
Build:
$ make
Test:
$ make test
Authored by Justin Tulloss, maintained by Shripad K and TJ Holowaychuk. To contribute please ensure all tests pass, and do your best to maintain the style used within the rest of the library.
Output of git summary
:
project: zeromq.node
commits: 260
files : 38
authors:
114 Justin Tulloss 43.8%
53 Tj Holowaychuk 20.4%
48 Stéphan Kochen 18.5%
12 jeremybarnes 4.6%
10 TJ Holowaychuk 3.8%
9 mike castleman 3.5%
3 Yaroslav Shirokov 1.2%
2 Corey Jewett 0.8%
2 mgc 0.8%
1 rick 0.4%
1 Matt Crocker 0.4%
1 Joshua Gourneau 0.4%
1 Micheil Smith 0.4%
1 Jeremy Barnes 0.4%
1 nponeccop 0.4%
1 Paul Bergeron 0.4%