gistfile1.clj

(defn- consumer-queue [dequeue]
  (lazy-seq
    (let [head (.take dequeue)]
      (cons head (consumer-queue dequeue)))))

(defn- send-in-batches [tweet-list]
  (loop [tweets tweet-list]
    (send-tweet-emails (take 2 tweets) (System/getenv "GMAIL_PASS"))
    (recur (drop 2 tweets))))

gistfile2.clj

(defn- add-tweet [queue tweet]
  (if (not (= tweet ""))(.offer queue tweet)))

(defn- parse-tweet [response]
  (:text (try (json/read-json (str response))
           (catch Exception e
             (println (str e " Parsing Exception"))
             {:text ""}))))

(defn- success_handler [queue]
  (fn [a response]
    (add-tweet queue (parse-tweet response))))


(defn-
  print-callback [queue]
  (AsyncStreamingCallback. (success_handler queue)
                           (comp println response-return-everything)
                           exception-print))

(defn fetch-tweets [queue oauth-credentials]
  (statuses-filter :params {:follow braintreeTwitterID}
                    :oauth-creds oauth-credentials
                    :callbacks (print-callback queue)))