                        (Executors/newCachedThreadPool)
                        (Executors/newCachedThreadPool)))
            all-channels (DefaultChannelGroup. (str "tcp-server " opts))
-           cpf (channel-pipeline-factory-factory
+           cpf (channel-pipeline-factory
                 (:pipeline-factory opts) (tcp-handler core all-channels))]
 
      ; Configure bootstrap

    (exceptionCaught [context ^ExceptionEvent exception-event]
      (warn (.getCause exception-event) "UDP handler caught"))))

(defn channel-pipeline-factory-factory
  "BOOM"
  [pipeline handler]
  (proxy [ChannelPipelineFactory] []
    (getPipeline []
      (doto (pipeline)
        (.addLast "executor" (ExecutionHandler.
                              (OrderedMemoryAwareThreadPoolExecutor.
                               16 1048576 1048576))) ; Maaagic values!

                     (NioDatagramChannelFactory.
                       (Executors/newCachedThreadPool)))
         all-channels (DefaultChannelGroup. (str "udp-server " opts))
         cpf (channel-pipeline-factory
              (:pipeline-factory opts) (udp-handler core all-channels))]

     ; Configure bootstrap
