def get( queue_name, opts = {} )
      opts = opts.merge( :queue_name => queue_name )
      g    = KJess::Request::Get.new( opts )

      if opts[:wait_for]
        wait_for_in_seconds = Float(opts[:wait_for]) / 1000.0
      else
        wait_for_in_seconds = 0.1
      end

      connection.with_additional_read_timeout(wait_for_in_seconds) do
        resp = send_recv( g )
        return resp.data if KJess::Response::Value === resp
        return nil
      end
    end
def get( queue_name, opts = {} )
      opts = opts.merge( :queue_name => queue_name )
      g    = KJess::Request::Get.new( opts )

      if opts[:wait_for]
        wait_for_in_seconds = Float(opts[:wait_for]) / 1000.0
      else
        wait_for_in_seconds = 0.1
      end

      connection.with_additional_read_timeout(wait_for_in_seconds) do
        resp = send_recv( g )
        return resp.data if KJess::Response::Value === resp
        return nil
      end
    end
Public: Retrieve an item from the given queue

 queue_name - the name of the queue to retrieve an item from
 options    - the options for retrieving the items
              :wait_for - wait for this many ms for an item on the queued(default: 0)
              :open     - count this as an reliable read (default: false)
              :close    - close a previous read that was retrieved with :open
              :abort    - close an existing read, returning that item to the head of the queue
              :peek     - return the first item on the queue, and do not remove it

 returns a Response