364365366367368369370371372373374
AsyncParticipantClient.getClient().sendRetryPreparedCommit(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
393394395396397398399400401402403
AsyncParticipantClient.getClient().sendRetryPreparedAbort(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
422423424425426427428429430431432
AsyncParticipantClient.getClient().sendRetryCommit(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
451452453454455456457458459460461
AsyncParticipantClient.getClient().sendPreparedAfterTimeout(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
480481482483484485486487488489490
AsyncParticipantClient.getClient().sendLostCommitted(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }