From b71e2dfee8c610149d7724eb9766a759e37c4777 Mon Sep 17 00:00:00 2001 From: Guillaume Buisson Date: Wed, 25 Mar 2015 16:39:54 +0100 Subject: [PATCH] log something as workaround for zk not triggering watcher --- project.clj | 2 +- src/clj_druid/client.clj | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/project.clj b/project.clj index 53b4da4..f74eed2 100644 --- a/project.clj +++ b/project.clj @@ -1,4 +1,4 @@ -(defproject y42/clj-druid "0.1.9" +(defproject y42/clj-druid "0.2.1" :description "Clojure library for Druid.io" :url "http://github.com/y42/clj-druid" :license {:name "MIT" diff --git a/src/clj_druid/client.clj b/src/clj_druid/client.clj index 40faf14..ed4c5e6 100644 --- a/src/clj_druid/client.clj +++ b/src/clj_druid/client.clj @@ -48,7 +48,9 @@ (-<>> path (zk/children zk-client <> :watch? true - :watcher #(do (zk-watch-node-list) zk-client path)) + :watcher #(do (println %) + (zk-watch-node-list zk-client path))) + (map #(data/to-string (:data (zk/data zk-client (str path "/" %))))) (map #(json/read-str %)) (map #(make-host-http-str %))