gistfile1.txt

CHILD NODE:

require 'rubygems'
require 'ffi-rzmq'

link = "tcp://127.0.0.1:5557"

context = ZMQ::Context.new 1
socket  = context.socket ZMQ::UPSTREAM

socket.connect link

while true do
#  message = ZMQ::Message.new
  puts socket.recv_string
end


CONTROL SERVER:

require 'rubygems'
require 'ffi-rzmq'

link = "tcp://127.0.0.1:5557"

context = ZMQ::Context.new 1
socket  = context.socket ZMQ::DOWNSTREAM

socket.bind link

message = ZMQ::Message.new "Hello World!"

socket.send message

socket.close



RUNNING THE CONTROL SERVER REPEATEDLY:

thebes:Desktop kunal$ ruby control-server.rb 
thebes:Desktop kunal$ ruby control-server.rb 
thebes:Desktop kunal$ ruby control-server.rb 
/Library/Ruby/Gems/1.8/gems/ffi-rzmq-0.5.0/lib/ffi-rzmq/wrapper.rb:50: [BUG] unexpected local variable assignment
ruby 1.8.7 (2009-06-08 patchlevel 173) [universal-darwin10.0]

Abort trap
thebes:Desktop kunal$ ruby control-server.rb 
/Library/Ruby/Gems/1.8/gems/ffi-rzmq-0.5.0/lib/ffi-rzmq/socket.rb:186: [BUG] Segmentation fault
ruby 1.8.7 (2009-06-08 patchlevel 173) [universal-darwin10.0]

Abort trap
thebes:Desktop kunal$ ruby control-server.rb 
control-server.rb:15: no block given (LocalJumpError)
thebes:Desktop kunal$ ruby control-server.rb 
thebes:Desktop kunal$ ruby control-server.rb 
thebes:Desktop kunal$ ruby control-server.rb 

OUTPUT FROM CHILDNODE :
thebes:Desktop kunal$ ruby child-node.rb 
Hello World!
Hello World!
Hello World!
Hello World!
Hello World!
Hello World!
Hello World!