DripDrop Ideas.rb

DripDrop::Node.new do |node|
  zpub = node.zmq_pub('tcp://127.0.0.1:2902')  #Create a ZMQ Pub Socket
  ws   = node.websocket('ws://127.0.0.1:2903') #Create a em-websocket websocket socket
  
  #Create a ZMQ Sub socket, and handle recv of DripDrop::Message messages
  node.zmq_sub('tcp://127.0.0.1:2904') do |message|
    message.body = message.decoded.body.upcase  
    zpub.send_message(message)   websocket.send_message(message)
  end
end

#... other nodes go here

DripDrop::NodePool.run