onyx.messaging.messenger-state

build-final-publication-info

(build-final-publication-info peer-opts job-id src-peer-id serialized-task [[site dst-task-id slot-id short-id] dsts])

messenger-connections

(messenger-connections {:keys [allocations peer-sites message-short-ids in->out], :as replica} {:keys [onyx.core/workflow onyx.core/catalog onyx.core/task onyx.core/serialized-task onyx.core/job-id onyx.core/id onyx.core/peer-opts], :as event})

next-messenger-state!

(next-messenger-state! messenger {:keys [onyx.core/job-id], :as event} old-replica new-replica)

transition-messenger

(transition-messenger messenger new-replica-version new-pub-subs)