         (let [unsafe-buffer (protocol/build-acker-message id (:id ack) (:completion-id ack) (:ack-val ack))]
           (send-pub messenger pub unsafe-buffer 0 protocol/ack-msg-length))))))
 
-(defn complete-message-short-circuit [ch completion-id]
-  (when ch
-    (>!! ch completion-id)))
-
 (defmethod extensions/internal-complete-message AeronConnection
   [messenger event completion-id {:keys [id channel] :as conn-info}]
   (if ((:short-circuitable? messenger) channel)

    (let [pub ^Publication (get-publication messenger conn-info)
          unsafe-buffer (protocol/build-completion-msg-buf id completion-id)]
      (send-pub messenger pub unsafe-buffer 0 protocol/completion-msg-length))))

(defn retry-segment-short-circuit [ch retry-id]
  (when ch
    (>!! ch retry-id)))

(defmethod extensions/internal-retry-segment AeronConnection
  [messenger event retry-id {:keys [id channel] :as conn-info}]

                 (= result publication-not-connected)))
      (.idle ^IdleStrategy (:send-idle-strategy messenger) 0))))


(defmethod extensions/send-messages AeronConnection
  [messenger event {:keys [id channel] :as conn-info} batch]
