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

   (println (str "**** Processing: " realtime-log-entry))
   (println (str @cached-queries))
   (println (str "Count: " (-> @cached-queries keys count str)))
   ;(let [queries (keys @cached-queries)]
;   (for [query queries]
     ;(println (str "   " queries)))
   ))




                                                "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
