         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 (not (offer-f))
+    (while (neg? (offer-f))
       (.idle ^IdleStrategy idle-strategy 0))))
 
 (defmethod extensions/close-peer-connection AeronConnection

        pub ^uk.co.real_logic.aeron.Publication (get-peer-link-pub peer-link :send-pub :send-pub-f-create)
        offer-f (fn [] (.offer pub unsafe-buffer 0 len))
        idle-strategy (:send-idle-strategy messenger)]
    (while (not (offer-f))
      (.idle ^IdleStrategy idle-strategy 0))))

(defmethod extensions/internal-ack-messages 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? (offer-f))
      (.idle ^IdleStrategy idle-strategy 0))))

(defmethod extensions/internal-retry-message AeronConnection
