           virtual-peers (atom {})
           publications (atom {})
           connections (atom {})
-          subscriber (start-subscriber! bind-addr port virtual-peers decompress-f)]
+          subscriber (start-subscriber! bind-addr port virtual-peers decompress-f receive-idle-strategy)]
       (assoc component 
              :bind-addr bind-addr
              :external-addr external-addr

            (>!! (:retry-ch (get @virtual-peers (:peer-id message))) 
                 retry-id)))))

(defn start-subscriber! [bind-addr port virtual-peers decompress-f]
  (let [ctx (.errorHandler (Aeron$Context.) no-op-error-handler)
        conn (Aeron/connect ctx)
        channel (aeron-channel bind-addr port)

                                    buffer offset length header)))

        subscription (.addSubscription conn channel send-stream-id)
        subscriber-fut (future (try (.accept ^Consumer (consumer handler idle-strategy 10) subscription) 
                                    (catch Throwable e (fatal e))))]
    {:conn conn :subscription subscription :subscriber-fut subscriber-fut}))

