365366367368369370371372373374375
AsyncParticipantClient.getClient().sendRetryPreparedCommit(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
394395396397398399400401402403404
AsyncParticipantClient.getClient().sendRetryPreparedAbort(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
423424425426427428429430431432433
AsyncParticipantClient.getClient().sendRetryCommit(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
452453454455456457458459460461462
AsyncParticipantClient.getClient().sendPreparedAfterTimeout(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }
481482483484485486487488489490491
AsyncParticipantClient.getClient().sendLostCommitted(coordinationContext, addressingProperties) ; callback.waitUntilTriggered(15000) ; } finally { initiator.removeCallback(messageId) ; } handleCallback(callback) ; }