Fixed bug: left a serizalize in the bus.

Author: reborg

README.md

@@ -41,7 +41,7 @@ The main selling point of Fluorine is to push toward a complete configuration so
 Check the current version at the top of the page if the one below is not the same.
 
 ```bash
-curl -O -L https://github.com/reborg/fluorine/releases/download/0.0.8/fluorine.jar
+curl -O -L https://github.com/reborg/fluorine/releases/download/0.0.9/fluorine.jar
 echo '{:fluorine-root "/path/to/data/folder"}' > fluorine.config
 java -jar fluorine.jar
 ```
@@ -53,7 +53,7 @@ Notice that `:fluorine-root` should point to the folder that Fluorine should wat
 Check the current version at the top of the page if the one below is not the same. Probably better to use the most recent.
 
 ```clojure
-:dependencies [[net.reborg/fluorine "0.0.8"]]
+:dependencies [[net.reborg/fluorine "0.0.9"]]
 ```
 
 ## How to use

demo/fluorine-client/project.clj

@@ -1,7 +1,7 @@
 (defproject fluorine-client "0.0.1"
   :description "Fluorine demo app"
   :dependencies [[org.clojure/clojure "1.8.0"]
-                 [net.reborg/fluorine "0.0.8"]
+                 [net.reborg/fluorine "0.0.9"]
                  ]
   :uberjar-name "fluorine-client.jar"
   :profiles {:uberjar {:main fluorine-client.core

project.clj

@@ -1,4 +1,4 @@
-(defproject net.reborg/fluorine "0.0.8"
+(defproject net.reborg/fluorine "0.0.9"
   :description "Distributed configuration for Clojure"
   :url "https://github.com/reborg/fluorine"
   :license {:name "Eclipse Public License - v 1.0"

src/net/reborg/fluorine/bus.clj

@@ -8,9 +8,6 @@
 
 (def ^:private clients (atom {}))
 
-(defn- serialize [x]
-  (with-out-str (clojure.pprint/write x)))
-
 (defn start [] (b/event-bus))
 
 (defn stop
@@ -26,7 +23,7 @@
   (fn [event]
     (b/publish! bus
                 (:channel event)
-                (serialize (:msg event)))))
+                (:msg event))))
 
 (defn init!
   "The bus needs to be bootstrapped after the change

src/net/reborg/fluorine_client.clj

@@ -62,7 +62,7 @@
     (s/consume
       (fn [new-cfg]
         (let [new-cfg (get-in (data/unmarshall new-cfg) kk)]
-          (log/info "Received new config" (diff @cfg new-cfg))
+          (let [d (diff @cfg new-cfg)] (log/info "Received new config. Diff:" (second d)))
           (reset! cfg new-cfg)))
       conn)))