569
}
570
571
>
u.instrumentation.countSent()
update.go
572
>
if u.state == stateSent {
573
u.instrumentation.countSentAgain()
574
}
575
576
>
if u.state == stateAdmitted {
update.go
577
>
u.setState(stateSent)
578
>
}
579
581
// This implies that the Update in the Registry derives from an UpdateAdmitted event exists;
582
// this event (which contains the request payload) is how the Update request will be communicated to the worker.
583
return nil
584
}
586
>
ProtocolInstanceId: u.id,
587
>
Id: u.outgoingMessageID(),
588
>
SequencingId: sequencingID,
589
>
Body: u.request,
590
>
}
591
}
592