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

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

(defn retry-message-short-circuit [ch retry-id]
  (>!! 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]
  (when ch 
    (doseq [ack acks]
      (>!! ch ack))))

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