 
 (defn handle-aux-message [daemon release-ch retry-ch buffer offset length header]
   (let [msg-type (protocol/read-message-type buffer offset)
-        offset-rest (long (inc offset))] 
+        offset-rest (inc ^long offset)] 
     (cond (= msg-type protocol/ack-msg-id)
           (let [ack (protocol/read-acker-message buffer offset-rest)]
             (acker/ack-message daemon (:id ack) (:completion-id ack) (:ack-val ack)))

        unsafe-buffer (protocol/build-retry-msg-buf id)
        pub ^uk.co.real_logic.aeron.Publication (get-peer-link-pub peer-link :aux-pub :aux-pub-f-create)
        offer-f (fn [] (.offer pub unsafe-buffer 0 protocol/retry-msg-length))]
    (while (neg? (offer-f))
      (.idle ^IdleStrategy idle-strategy 0))))

(defmethod extensions/close-peer-connection AeronConnection

        unsafe-buffer (protocol/build-completion-msg-buf id)
        pub ^uk.co.real_logic.aeron.Publication (get-peer-link-pub peer-link :aux-pub :aux-pub-f-create)
        offer-f (fn [] (.offer pub unsafe-buffer 0 protocol/completion-msg-length))]
    (while (neg? ^long (offer-f))
      (.idle ^IdleStrategy idle-strategy 0))))

(defmethod extensions/internal-retry-message AeronConnection
