router-router.coffee

zmq = require 'zmq'
address = 'inproc://foobar'

class Cycle
  constructor: (@items) ->

  next: ->
    @items.push(item = @items.shift())
    return item


channelA = zmq.socket 'router'
channelA.identity = 'channel-A'
channelA.on 'message', (envelope, message) -> 
  console.log "#{envelope} sent back #{message}"

channelB = zmq.socket 'router'
channelB.identity = 'channel-B'
channelB.on 'message', (envelope, number) -> 
  channelB.send [envelope, parseInt(number) + parseInt(number)]

channelC = zmq.socket 'router'
channelC.identity = 'channel-C'
channelC.on 'message', (envelope, number) ->
  channelC.send [envelope, number * number]


cycle = new Cycle(['channel-B', 'channel-C'])

channelA.bind address, ->
  channelC.connect address
  channelB.connect address
  num = 10;
  setInterval(->
    env = cycle.next()
    console.log "sending #{num} to #{env}"
    channelA.send [env, num++]
  , 2000)