7475767778798081828384
AsyncParticipantClient.getClient().sendCancel(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
103104105106107108109110111112113
AsyncParticipantClient.getClient().sendExit(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
132133134135136137138139140141142
AsyncParticipantClient.getClient().sendFail(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
161162163164165166167168169170171
AsyncParticipantClient.getClient().sendCannotComplete(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
190191192193194195196197198199200
AsyncParticipantClient.getClient().sendParticipantCompleteClose(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
219220221222223224225226227228229
AsyncParticipantClient.getClient().sendCoordinatorCompleteClose(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
248249250251252253254255256257258
AsyncParticipantClient.getClient().sendUnsolicitedComplete(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
277278279280281282283284285286287
AsyncParticipantClient.getClient().sendCompensate(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
306307308309310311312313314315316
AsyncParticipantClient.getClient().sendCompensationFail(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
335336337338339340341342343344345
AsyncParticipantClient.getClient().sendParticipantCancelCompletedRace(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }