call create queue until it succeeds

dakrone · Jul 24, 2011 · 6a66199 · 6a66199
1 parent 0679e20
commit 6a66199
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/src/Howler/core.clj b/src/Howler/core.clj
@@ -32,7 +32,16 @@
   (secure? [acct] (:secure? acct false)))
 
 (defn connect-to-queue [account queue-name]
-  (.getOrCreateMessageQueue (queue-service account) queue-name))
+  (letfn [(f []
+            (try
+              (.getOrCreateMessageQueue (queue-service account) queue-name)
+              (catch Exception e
+                (.printStackTrace e)
+                (Thread/sleep 1000))))]
+    (loop [x nil]
+      (if-not x
+        (recur (f))
+        x))))
 
 (defmulti -main (fn [x & _] x))
 
@@ -129,6 +138,8 @@
         (first (shuffle i))
         i))))
 
+;; 
+
 (defn add-icon [x m]
   ((if-let [icon (icon (:recipient m))]
      #(assoc % :image icon)