         (let [[[user connector] ch] (alts! [chan (timeout timeout-processing-loop)])]
           (when (not-nil? user)
             (try
-              (log/log-debug (str "executing collect request for " (.getName user) " and " (.getConnectorInstanceName connector)))
+              (log/log-debug (str "executing collect request for " (get-name user) " and " (.getConnectorInstanceName connector)))
               (collect! user connector)
               (if (updator/metering-enabled?)
                 (update-metric! user))

        (when (nil? v)
          (log/log-error
            "Timeout collecting vms for user "
            (.getName user)
            " on cloud "
            (.getConnectorInstanceName connector)))))
    (go (>! ch (Collector/collect user connector)))))

        (if (nil? res)
          (log/log-error
            "Timeout updating metrics for user "
            (get-name user))
          (log/log-info (str "executed update-metric request for " (get-name user))))))
    (go (>! ch (updator/update user)))))

(def not-nil? (complement nil?))
