Connecting to ZMQ firehose

client.coffee

tail = (channel, callback) ->
  socket = require('zeromq').createSocket('sub')
  socket.connect("tcp://IP_ADDRESS:5555")
  socket.subscribe(channel)
  socket.on 'message', (ch, data) -> callback(JSON.parse(data.toString('utf8')))

tail 'channame', (row) -> console.log(row)

client.rb

require 'rubygems'
require 'ffi-rzmq'

context = ZMQ::Context.new(1)

subscriber = context.socket(ZMQ::SUB)
subscriber.connect("tcp://IP_ADDRESS:5555")

subscriber.setsockopt(ZMQ::SUBSCRIBE, "")

count = 0
start = Time.now

while true do   
  body = subscriber.recv_string
  puts body
end