lazy-jms-queue-consumer.clj

(defn- lazy-queue-message-seq [^QueueReceiver receiver]
  (lazy-seq
   (let [message (.receive receiver)]
     (cons message (lazy-queue-message-seq receiver)))))

(defn queue-message-seq
  "Receive a lazy sequence of messages from the JMS Queue"
  [queue]
  (let [^QueueSession session (.createQueueSession *jms-queue-connection*   false Session/AUTO_ACKNOWLEDGE)
        ^QueueReceiver receiver (.createReceiver session (.createQueue session  queue))]
    (.start *jms-queue-connection*)
    (lazy-queue-message-seq receiver)))