      (jdbc/find-connection)))
 
 
+
+
   )
     ;; did not get the lock
     false))
  )

(defn process-row-changes [conf conn]
  ;; obtain mutex, nowait

           (when (not (empty? recs))
             ;; TODO: Instead of NxM, we could group the list of records by schema_name.table_name and pass them
             ;; to the observer-fn as a seq
             (doseq [[[schema-name table-name] recs] (group-row-updates recs)]
               (doseq [[observer-name observer-fn] (find-listeners dbname schema-name table-name)]
                 (observer-fn recs))
               (doseq [rec recs]
                 (jdbc/do-prepared "DELETE FROM irmgard.row_changes WHERE event_id=?" [(:event_id rec)])))
             (recur (exec-sql "SELECT * FROM irmgard.row_changes ORDER BY event_id LIMIT 100" [])))))
       (log/infof "did not get lock on irmgard.process_log, another process is working with the table."))
     :ok)))
