connection.rb

# ruby -v => ruby 1.8.7 (2010-01-10 patchlevel 249) [i686-darwin10]
RUBY_ENGINE = 'ruby'
require 'rubygems'
gem 'ffi-rzmq'
gem 'json'
require 'ffi-rzmq'
require 'json'
require 'request'
CTX = ZMQ::Context.new(1)

  class Connection
  
    def initialize(sender_id, sub_addr, pub_addr)
      @sender_id = sender_id

      reqs = CTX.socket(ZMQ::UPSTREAM)
      reqs.connect(sub_addr)

      resp = CTX.socket(ZMQ::PUB)
      resp.connect(pub_addr)
      resp.setsockopt(ZMQ::IDENTITY, sender_id)

      @sub_addr = sub_addr
      @pub_addr = pub_addr
      @reqs = reqs
      @resp = resp
    end
  end