   (format "udp://%s:%s" addr port))
 
 (defrecord AeronMessenger
-    [peer-group messaging-group publication-group short-circuitable?
-     publications virtual-peers acking-daemon acking-ch send-idle-strategy
-     compress-f]
+  [peer-group messaging-group publication-group short-circuitable? publications virtual-peers 
+   acking-daemon send-idle-strategy compress-f monitoring publication-pool short-ids acking-ch]
   component/Lifecycle
 
   (start [component]

    (let [pub-man (get-publication (:publication-pool messenger) conn-spec)
          buf ^UnsafeBuffer (protocol/build-acker-messages acker-id acks)
          size (.capacity buf)]
      (extensions/emit (:onyx.core/monitoring event) (->MonitorEventBytes :peer-send-bytes size))
      (pubm/write pub-man buf 0 size))))

(defmethod extensions/internal-complete-segment AeronMessenger


(defn ack-segments-short-circuit [ch acks]
  (when ch
    (run! (fn [ack]
            (>!! ch ack))
          acks)))

(defn complete-message-short-circuit [ch completion-id]
  (when ch
