 (defn send-ok-messages [c buffer]
   (if-let [result (aq/peek-head buffer)]
     (do
-      (println "Sending ok" result)
       (go (>! c result))
       (send-ok-messages c (aq/remove-one buffer)))
     buffer))


(defmacro super-reduce [f xs]
  `(invoke-lambda (pr-str (s/fn [] (reduce ~f ~xs))) "distributed-transducers-poc" "eu-west-1"))

(defn plus [a b]
  (+ a b))

(def sqs-client (AmazonSQSClient. aws-credentials))


  (let [handler (fn [message]
                  (when (= "process" (:type message)
                           (let [result (f (:payload message))]
                             (send-message out-queue {:index (:index message)
                                                      :payload result}))))
                    (:type message))]
