zmq_reqres

A CoffeeScript implementation of ZeroMQ request/response model

ZMQ request/response model implementation

npm install zmq_reqres

cake build;coffee ./example/test

# Start broker 
Broker = require '../lib/broker'
broker = new Broker()
 
# Start responder 
Responder = require '../lib/responder'
responder = new Responder()
 
Sender = require '../lib/sender'
sender = new Sender()
 
totalCount = 1
count = 0
 
# 'Reverse' is a system worker for testing purpose 
for i in [0...totalCount]
  data = "Hello: #{i}"
  handle = sender.send 'Reverse'data
 
  handle.on "submit"=>
    console.log "Submitted: %s"handle.id
 
  handle.on "complete"(data) =>
    count++
    console.log "Completed: %s (%s)"data.handle.iddata.result
    if count is totalCount
      console.log 'Total count:'count
      process.exit(0)
 
  handle.on "error"(error) =>
    count++
    console.error "Failed: %s (%s)"data.handle.iderror
    if count is totalCount
      console.log 'Total count:'count
      process.exit(0)