lazy-seq connect-to-broker

gistfile1.clj

(defn connect-to-broker
  ([config] (connect-to-broker config 5))
  ([config max-tries]
   (first (drop-while nil? (connect-to-broker config max-tries 1))))
  ([config max-tries attempt]
   (if (<= attempt max-tries)
     (try
       [(rmq/connect config)]
       (catch Throwable t
         (log/warn "RabbitMQ not available:" (.getMessage t) "attempt:" attempt)
         (lazy-seq
          (Thread/sleep (* attempt 1000))
          (connect-to-broker config max-tries (inc attempt)))))
     nil)))