clojure udp aleph example

server.clj

(ns statsd-clj.server
  (:use [aleph.udp]
        [gloss core io]
        [lamina core api])
  (:require [statsd-clj.config :as config]
            [statsd-clj.metrics :as metrics]
            [clojure.tools.logging :as log]))

(def socket-server (agent nil))

(defn create-server
  [host port]
    (udp-socket
      {:frame  (string :utf-8 :as-str true)
       :port port
       :address host}))

(defn start
  [host port]
  (log/infof "statsd udp server [%s:%s]: starting" host port)
  (send socket-server #(or % (create-server host port)))
  (receive-all @socket-server #(metrics/capture-metric (:message %)))
  (log/info "statsd udp server: started"))

(defn stop
  []
  (log/info "statsd udp server: stopping")
  (send socket-server close)
  (shutdown-agents)
  (log/info "statsd udp server stopped"))