class Protobuf::Rpc::Zmq::Worker

def initialize(options = {})
  host = options[:host]
  port = options[:port]
  @zmq_context = ::ZMQ::Context.new
  @socket = @zmq_context.socket(::ZMQ::REQ)
  zmq_error_check(@socket.connect("tcp://#{resolve_ip(host)}:#{port}"))
  @poller = ::ZMQ::Poller.new
  @poller.register(@socket, ::ZMQ::POLLIN)
  # Send request to broker telling it we are ready
  zmq_error_check(@socket.send_string(::Protobuf::Rpc::Zmq::WORKER_READY_MESSAGE))
end