Reuse connection in worker

QueueWorker

(defrecord QueueWorker [queue worker-fn]
  daemon/Daemon
  (start [_]
    (reset! done false)
    (msg/with-connection {} ; use single connection for receive                                                                                                                                                    
      (loop []
        (when-not @done
          ;; make sure we re-use the same HornetQ connection                                                                                                                                                       
          (info "Worker Connection" (:connection ((get-thread-bindings) #'immutant.messaging.core/*options*)))                                                                                       
          (when-let [msg (msg/receive queue :timeout 5000)]
            (worker-fn msg))
          (recur)))))
  (stop [_]
    (reset! done true)))