 
 ;; Tests to make sure SNS/SQS is working
 (comment
+  ; (.subscribe (:sns-client broker) "arn:aws:sns:us-east-1:688991608580:gsfc-eosdis-cmr-ingest_exchange" "sqs" "arn:aws:sqs:us-east-1:688991608580:gsfc-eosdis-cmr-ngap-cmr-test_queue")
   ;; create a broker
   (def broker (lifecycle/start (create-queue-broker {}) nil))
   ;; list the topics for the cmr-ingest_exchange exchange/topic
   (get-topic (:sns-client broker) "cmr_ingest_exchange")
   ;; list the queues for the cmr_ingest_exchange
-  (queue/get-queues-bound-to-exchange broker "cmr_ingest_exchange")
+  (queue/get-queues-bound-to-exchange broker "ngap-cmr_testB_exchange")
   ;; create a test queue
-  (create-queue (:sqs-client broker) "cmr-test.queue")
+  (create-queue (:sqs-client broker) "test-ABG")
   ;; create a test exchange
-  (create-exchange (:sns-client broker) "cmr_test_exchange")
+  (create-exchange (:sns-client broker) "ngap-cmr_testB_exchange")
   ;; list the queues for the cmr_test_exchange
   (queue/get-queues-bound-to-exchange broker "cmr_test_exchange")
   ;; Bind the queue to the new exchange
-  (bind-queue-to-exchanges (:sns-client broker) (:sqs-client broker) ["cmr_test_exchange"] "cmr-test.queue")
+  (bind-queue-to-exchanges (:sns-client broker) (:sqs-client broker) ["ngap-cmr_testB_exchange"] "test-ABG")
   ;; subscribe to test queue with a simple handler that prints received messages
   (queue/subscribe broker "cmr-test.queue" (fn [msg] (println "Got Message: " msg)))
   ;; publish a message to the queue to verify our subscribe worked
   (queue/publish-to-queue broker "cmr-test.queue" "{\"body\": \"ABC\"}")
   ;; publish a message to the exchange to verify the message is sent to the queue
-  (queue/publish-to-exchange broker "cmr_test_exchange" "{\"body\": \"ABC-exchange\"}"))
+  (queue/publish-to-exchange broker "ngap-cmr_testB_exchange" "{\"body\": \"ABC-exchange\"}"))

   [cmr.message-queue.services.queue :as queue])
  (:import
   (com.amazonaws ClientConfiguration)
   (com.amazonaws.auth.policy Condition Policy Principal Statement Statement$Effect)
   (com.amazonaws.auth.policy.actions SQSActions)
   (com.amazonaws.auth.policy.conditions ConditionFactory)
   (com.amazonaws.services.sns AmazonSNSClient)

       q-arn (get-queue-arn sqs-client q-name)
       q-url (.getQueueUrl (.getQueueUrl sqs-client q-name))
       ;; create an access policy to allow the topic to publish to the queue
       access-policy (sns-to-sqs-access-policy sns-client sqs-client q-name exchange-names)
       q-attrs (HashMap. {"Policy" access-policy})

       ;; create an empty SetQueueAttributesRequest object and then set the attributes on it
       set-queue-attrs-request (doto (SetQueueAttributesRequest.)
                                     (.setAttributes q-attrs)
                                     (.setQueueUrl q-url))]
