                                                 "realtime_jvm_id = ?")
                     ]
                      (let [get-new-entry-count    (korma.core/exec-raw [sql [next-id]] []) ]
+                       (do
                        (println "processing: " get-new-entry-count )
+                       ;(println (str @cached-queries))
                         (if (pos? (first get-new-entry-count))
                           (do
                         (let [realtime-log-entry-list

                          (go
                            (if realtime-log-entry
                               (>! server-side-record-changes  realtime-log-entry)))
                          )))
                 ))) my-pool )



  (loop []
    (do
        (let [realtime-log-entry   (<! server-side-record-changes)]
            (process-log-entry  realtime-log-entry )
        )
        (recur)
      )
