rabbit.js subscriber and publisher

gistfile1.js

// Subscriber
var context = require('rabbit.js').createContext();

context.on('ready', function() {
        var pub = context.socket('PUB'), sub = context.socket('SUB');
        sub.pipe(process.stdout);
        sub.connect('events');
        sub.setEncoding('utf8');
        sub.on('events', function(data) {
                console.log(data);
        });
});

// Publisher
context = require('rabbit.js').createContext();

context.on('ready', function() {
  var pub = context.socket('PUB'), sub = context.socket('SUB');
  sub.pipe(process.stdout);
    pub.connect('events', function() {
        setInterval(function() {
                pub.write('hello world from server', 'utf8');
        }, 500);
    });
});