                  (= result publication-not-connected)))
       (.idle ^IdleStrategy (:send-idle-strategy messenger) 0))))
 
-(defn send-messages-short-circuit [ch batch]
-  (when ch
-    (doseq [segment batch]
-      (>!! ch segment))))
 
 (defmethod extensions/send-messages AeronConnection
   [messenger event {:keys [id channel] :as conn-info} batch]

        (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)
          [len unsafe-buffer] (protocol/build-messages-msg-buf (:compress-f messenger) id batch)]
      (send-pub messenger pub unsafe-buffer 0 len))))

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