Ja raczej widziałem onPeerCapabilitiesChanged jako sposób informowania o tym jakie taski mogą być wykonywane na jakim peerze (bo nie każdy od razu ma załadowany kod do zadania).
To czy job był zaakcpetowany - po to są ACKi. 
Informacja o tym, że został zrobiony - sorry, przeoczyłem. ResultAggregator powinien mówić temu modułowi że Job X jest zrobiony, wtedy reagujesz wysyłaniem kolejnych. Moduł ten powinien jednak mieć pewne timeouty na wypadek gdyby peer chciał nas spowolnić.