tag doesnt work

graphite

; (5556)
(let [host "0.0.0.0"]
  (tcp-server :host host)
  (udp-server :host host)
  (ws-server  :host host)
  (graphite-server :host host))



(streams
  ( where (service =~ "%servers%")
     ( tag "graphite" )
  )

  (tagged-all "graphite" prn )
  (let [client (tcp-client :host "192.168.19.1")]
      (by [:host :service]
         (forward client))))

(let [host "0.0.0.0"
      client (tcp-client :host "192.168.19.1")]
  (tcp-server :host host)
  (udp-server :host host)
  (ws-server  :host host)
  (graphite-server :host host)



(streams
  (where (service #".*servers.*")
    (tag "graphite"
          (tagged-all "graphite" prn )))

  (tagged-all "graphite" prn )
  (by [:host :service]
      (forward client))))

the above had a bug. Try this:

(let [host "0.0.0.0"
      client (tcp-client :host "192.168.19.1")]
  (tcp-server :host host)
  (udp-server :host host)
  (ws-server  :host host)
  (graphite-server :host host)



  (streams
    (where (service #".*servers.*")
      (tag "graphite"
           (tagged-all "graphite" prn ))

      (tagged-all "graphite"
                  prn
                  (by [:host :service]
                      (forward client))))))

(let [host "0.0.0.0"
client (tcp-client :host "192.168.19.1")](tcp-server :host host)
(udp-server :host host)
(ws-server :host host)
(graphite-server :host host)

(streams
(where (service #".servers.")
(tag "graphite"
(tagged-all "graphite" prn )
(by [:host :service](forward client))))

))

(let [host "0.0.0.0"
      client (tcp-client :host "192.168.19.1")]
  (tcp-server :host host)
  (udp-server :host host)
  (ws-server  :host host)
  (graphite-server :host host)



(streams
  (where (service #".*servers.*")
    (tag "graphite"
          (tagged-all "graphite" prn )
          (by [:host :service]
            (forward client)))
     (else(by [:host :service] (forward client))))

))

(ns riemann.graphite)
(defn graphite-path-basic [event]
  (let [service (:service event)
        host (:host event)
        split-service (if service (split service #" ") [])
        split-host (if host (split host #"\.") [])]
     (join "." (concat (reverse split-host) split-service))))
(ns riemann.config)

Using local /usr/local/java/jdk-7u25

INFO [2013-12-29 17:26:14,091] main - riemann.bin - PID 13269

ERROR [2013-12-29 17:26:14,120] main - riemann.bin - Couldn't start
java.lang.IllegalStateException: replace already refers to: #'clojure.string/replace in namespace: riemann.graphite
at clojure.lang.Namespace.warnOrFailOnReplace(Namespace.java:88)
at clojure.lang.Namespace.reference(Namespace.java:110)
at clojure.lang.Namespace.refer(Namespace.java:168)
at clojure.core$refer.doInvoke(core.clj:3850)
at clojure.lang.RestFn.invoke(RestFn.java:410)
at riemann.graphite$eval31$loading__4910__auto____32.invoke(riemann.config:8)
at riemann.graphite$eval31.invoke(riemann.config:8)
at clojure.lang.Compiler.eval(Compiler.java:6619)
at clojure.lang.Compiler.eval(Compiler.java:6608)
at clojure.lang.Compiler.load(Compiler.java:7064)
at clojure.lang.Compiler.loadFile(Compiler.java:7020)
at clojure.lang.RT$3.invoke(RT.java:318)
at riemann.config$include.invoke(config.clj:285)
at riemann.bin$_main.doInvoke(bin.clj:61)
at clojure.lang.RestFn.applyTo(RestFn.java:137)
at riemann.bin.main(Unknown Source)

(defn graphite-path-sarguru [event]
(let [service (:service event)
        host (:host event)
        split-service (if service (split service #" ") [])
        split-host (if host (split host #"\.") [])]
     (string/join "." ( split-service)))
 )


(def graph (graphite {:host "10.128.35.105" :path "graphite-path-sarguru"}))

(defn graphite-path-sarguru [event]
(let [service (:service event)]
     service )
 )


(def graph (graphite {:host "10.128.35.105" :path "graphite-path-sarguru"}))

(defn graphite-path-sarguru [event]
(let [service (:service event)]
     service )
 )


(def graph (graphite {:host "10.128.35.105" :path graphite-path-sarguru}))