 
             sync-spy-a (chan 1)
             sync-spy-b (chan 1)
+            ack-ch-spy (chan 2)
             offer-ch-spy (chan 1)
             
             catalog [{:onyx/name :in

                payload-b (extensions/read-place sync payload-node-b)]
            (is (not (nil? payload-a)))
            (is (not (nil? payload-b)))
            (is (not= payload-a payload-b))))))
    {:eviction-delay 50000}))

(run-tests 'onyx.coordinator.multi-peer-test)

                      :hornetq/queue-name "out-queue"}]
            workflow {:in {:inc :out}}]

        (tap (:ack-mult coordinator) ack-ch-spy)
        (tap (:offer-mult coordinator) offer-ch-spy)

        (extensions/write-place sync peer-node-a payload-node-a)
