def consume_one(timeout)
      msg = nil

      Rafka.wrap_errors do
        msg = @redis.blpop(@blpop_arg, timeout: timeout)
      end

      msg = Message.new(msg) if msg
      msg
    end
def consume_one(timeout)
      msg = nil

      Rafka.wrap_errors do
        msg = @redis.blpop(@blpop_arg, timeout: timeout)
      end

      msg = Message.new(msg) if msg
      msg
    end
@param timeout [Fixnum]

 @raise [MalformedMessageError]

 @return [nil, Message]