         (update-in [:accepted] dissoc accepted-observer)
         (update-in [:peers] vec)
         (update-in [:peers] conj accepted-joiner)
-        (assoc-in [:peer-state accepted-joiner] :idle))))
+        (assoc-in [:peer-state accepted-joiner] :idle)
+        (reconfigure-cluster-workload))))
 
 (defmethod extensions/replica-diff :accept-join-cluster
   [entry old new]

          (>!! (:outbox-ch state) entry))
        (assoc (dissoc state :buffered-outbox) :stall-output? false))
    state))


(defmethod extensions/reactions :accept-join-cluster
  [entry old new diff state]
  [])

(defn unbuffer-messages [state diff new]
  (if (= (:id state) (:subject diff))
    (do (extensions/open-peer-site (:messenger state) 
                                   (get-in new [:peer-sites (:id state)]))
