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

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

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