config

(ns riemann.config
 (:require [riemann.streams :refer [batch forward]]
           [riemann.config :refer [async-queue!]]))

(def mc-downstream
  (batch 100 1/10
    (async-queue! :agg {:queue-size 1e3}
                  :core-pool-size 4
                  :max-pool-size 32
      (forward (riemann.client/tcp-client :host "localhost")))))
(logging/init {:file "/var/log/riemann/riemann.log"})

;; Listen on the local interface over TCP (5555), UDP (5555), websockets
;; (5556) and REPL (5557)
(io
 (let [host "0.0.0.0"]
   (tcp-server {:host host})
   (udp-server {:host host})
   (ws-server {:host host})
   (repl-server {:host host})))

(periodically-expire 5)

(let [index (index)]
      

  (streams
    (default :ttl 60
      (where (service #"^riemann.*")
        mc-downstream
        index))))

riemann forwarder service error

WARN [2017-02-08 14:13:28,092] pool-6-thread-1 - riemann.streams - 32 threw
java.lang.ClassCastException: java.lang.Long cannot be cast to clojure.lang.IFn
	at riemann.streams$execute_on$stream__6765$runner__6766$fn__6771.invoke(streams.clj:268)
	at riemann.streams$execute_on$stream__6765$runner__6766.invoke(streams.clj:268)
	at clojure.lang.AFn.applyToHelper(AFn.java:152)
	at clojure.lang.AFn.applyTo(AFn.java:144)
	at clojure.core$apply.invokeStatic(core.clj:646)
	at clojure.core$with_bindings_STAR_.invokeStatic(core.clj:1881)
	at clojure.core$with_bindings_STAR_.doInvoke(core.clj:1881)
	at clojure.lang.RestFn.invoke(RestFn.java:425)
	at clojure.lang.AFn.applyToHelper(AFn.java:156)
	at clojure.lang.RestFn.applyTo(RestFn.java:132)
	at clojure.core$apply.invokeStatic(core.clj:650)
	at clojure.core$bound_fn_STAR_$fn__4671.doInvoke(core.clj:1911)
	at clojure.lang.RestFn.invoke(RestFn.java:397)
	at clojure.lang.AFn.run(AFn.java:22)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)