From 7ae72ff7d927bb267f08b3b4ed7e2fc8f4d28787 Mon Sep 17 00:00:00 2001
From: Chas Emerick <chas@cemerick.com>
Date: Fri, 24 Feb 2012 10:09:31 -0500
Subject: [PATCH] test tweaks

---
 src/test/clojure/cemerick/bandalore_test.clj | 33 +++++++++-----------
 1 file changed, 15 insertions(+), 18 deletions(-)

diff --git a/src/test/clojure/cemerick/bandalore_test.clj b/src/test/clojure/cemerick/bandalore_test.clj
index f7f342a..b7fd029 100644
--- a/src/test/clojure/cemerick/bandalore_test.clj
+++ b/src/test/clojure/cemerick/bandalore_test.clj
@@ -1,13 +1,8 @@
 (ns cemerick.bandalore-test
   (:use cemerick.bandalore
-    clojure.test
-    clojure.contrib.core)
+    clojure.test)
   (:refer-clojure :exclude (send)))
 
-#_(do
-    (System/setProperty "aws.id" "")
-    (System/setProperty "aws.secret-key" ""))
-
 ; kill the verbose aws logging
 (.setLevel (java.util.logging.Logger/getLogger "com.amazonaws")
   java.util.logging.Level/WARNING)
@@ -56,11 +51,8 @@
   `(deftest ~name
      (println '~name) ; lots of sleeping in these tests, give some indication of life
      (binding [*test-queue-url* (create-queue client (test-queue-name))]
-       (try
-         (is *test-queue-url*)
-         ~@body
-         (finally
-           (delete-queue client *test-queue-url*))))))
+       (is *test-queue-url*)
+       ~@body)))
 
 (defsqstest test-list-queues
   (let [msg (uuid)]
@@ -70,16 +62,21 @@
       "Created queue not visible in result of list-queues")))
 
 (defsqstest test-queue-attrs
-  (let [{:strs [VisibilityTimeout MaximumMessageSize] :as base-attrs} (queue-attrs client *test-queue-url*)
-        expected {"VisibilityTimeout" "117" "MaximumMessageSize" "1535"}]
-    (is (and VisibilityTimeout MaximumMessageSize))
+  (let [{:strs [MaximumMessageSize] :as base-attrs} (queue-attrs client *test-queue-url*)
+        expected {"MaximumMessageSize" "1535"}]
+    (is MaximumMessageSize)
     (queue-attrs client *test-queue-url* expected)
-    (wait-for-condition #(= expected
-                           (->> (queue-attrs client *test-queue-url*)
-                             (filter (comp (set (keys expected)) first))
-                             (into {})))
+    (wait-for-condition #(= expected (select-keys (queue-attrs client *test-queue-url*) (keys expected)))
       "Queue attribute test failed after waiting for test condition")))
 
+(defsqstest receive-delete
+  (let [msg (uuid)]
+    (send client *test-queue-url* msg)
+    (let [[{:keys [body] :as rmsg}] (receive client *test-queue-url*)]
+      (is (= msg body))
+      (delete client *test-queue-url* rmsg)
+      (is (empty? (receive client *test-queue-url*))))))
+
 (defn- wait-for-full-queue
   [q min-cnt queue-name]
   (wait-for-condition #(-> (queue-attrs client q)