         (.idle ^IdleStrategy idle-strategy 0)))))
 
 (defn retry-message-short-circuit [ch retry-id]
-  (>!! ch retry-id))
+  (when ch 
+    (>!! ch retry-id)))
 
 (defmethod extensions/internal-retry-message AeronConnection
   [messenger event retry-id {:keys [id channel] :as conn-info}]

        (.idle ^IdleStrategy idle-strategy 0)))))

(defn ack-messages-short-circuit [ch acks]
  (doseq [ack acks]
    (>!! ch ack)))

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

      ch-k))

(defn send-messages-short-circuit [ch batch]
  (when ch 
    (doseq [segment batch]
      (>!! ch segment))))

(def ^:const publication-backpressured? (long -2))

