broker

gistfile1.txt

    brokerListener = zmq.socket('pull')

    brokerListener.identity = 'Broker Listener:' + process.pid

    brokerListener.connect(nconf.get('busUri'))

    console.log("#{brokerListener.identity} created.")

    brokerListener.on('message', (type, data) ->
      console.log("Broker Listener " + brokerListener.identity + ': received type' + type + ', data [' + data.toString() + ']')
      switch type
        when 'ImageProcessor'
          imageProcessor.send(data)
        else
          articleProcessor.send(data)
    )

    imageProcessorBus = zmq.socket('push')
    imageProcessorBus.identity = 'imageProcessor Bus:' + process.pid
    imageProcessorBus.bind(nconf.get('imageProcessorPort'))
    console.log("#{imageProcessorBus.identity} created")

    articleProcessorBus = zmq.socket('push')
    articleProcessorBus.identity = 'articleProcessor Bus:' + process.pid
    articleProcessorBus.bind(nconf.get('articleProcessorPort'))
    console.log("#{articleProcessorBus.identity} created")