def run
      while true
        message = @socket.read_multipart
        if @socket.is_a? Celluloid::ZMQ::RouterSocket
          message = message[1]
        else
          message = message[0]
        end
        handle_message message
      end
    end
def run
      while true
        message = @socket.read_multipart
        if @socket.is_a? Celluloid::ZMQ::RouterSocket
          message = message[1]
        else
          message = message[0]
        end
        handle_message message
      end
    end
Wait for incoming 0MQ messages