push pull with waterfront.

broker.js

var waterfront = require("waterfront")

waterfront.listen()

dispatcher.js

var waterfront = require('waterfront').connect()
var sock       = waterfront.socket('push')

setInterval(function(){
  process.stdout.write('.')
  sock.send({ "date" : (+new Date) })
}, 200)

worker.js

var waterfront = require('waterfront').connect()
var sock       = waterfront.socket('pull')

sock.on("message", function(data){
  console.log(data)
})