Celluloid Client-1.

client1.rb

require 'celluloid/zmq'
Celluloid::ZMQ.init

class Client
  include Celluloid::ZMQ

  def initialize
    @socket = Socket::Push.new

    begin
      @socket.connect('tcp://192.168.1.10:3435')
    rescue IOError
      @socket.close
      raise
    end
  end

  def write(message)
    @socket.send(message)
    nil
  end
end

client = Client.new()

##  pass client-1 so that server goes to sleep.
client.write('client-1')