           daemon (:acking-daemon component)
           release-ch (chan (clojure.core.async/dropping-buffer 100000))
 
-          port (+ 40000 (rand-int 250))
+          port (+ 40000 (rand-int 10000))
           channel (str "udp://localhost:" port)
 
           rand-stream-id (fn [] (rand-int 1000000))

          (let [fragments-read (.poll subscription limit)]
            (.idle idle-strategy fragments-read)))))))

(defrecord AeronConnection [opts]
  component/Lifecycle


          completion-stream-id (rand-stream-id)

          driver (MediaDriver/launch)
          ctx (.errorHandler (Aeron$Context.) no-op-error-handler)
          aeron (Aeron/connect ctx)

          send-handler (data-handler (partial handle-sent-message inbound-ch))
