   "A decoder that turns DatagramPackets into ByteBufs."
   []
   (proxy [MessageToMessageDecoder] []
-    (decode [context ^DatagramPacket message out]
+    (decode [context ^DatagramPacket message ^List out]
       (.add out (retain (.content message))))
 
     (isSharable [] true)))

        clojure.tools.logging)
  (:require [riemann.query       :as query])
  (:import
    (java.util.concurrent TimeUnit
                          Executors)
    (com.aphyr.riemann Proto$Msg)
    (io.netty.channel ChannelInitializer
                      Channel
                      ChannelHandler)
    (io.netty.channel.group ChannelGroup
                            DefaultChannelGroup)

  "Netty decoder for Msg protobuf objects -> maps"
  []
  (proxy [MessageToMessageDecoder] []
    (decode [context message ^List out]
      (.add out (decode-msg message)))
    (isSharable [] true)))

