nizhikov commented on code in PR #10314:
URL: https://github.com/apache/ignite/pull/10314#discussion_r1069491997
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java:
##########
@@ -3130,6 +3143,50 @@ public DistributedTransactionConfiguration
getDistributedTransactionConfiguratio
return distributedTransactionConfiguration;
}
+ /** @param transform Transaction message transformer. */
+ public void txMessageTransformer(BiFunction<GridCacheMessage,
IgniteInternalTx, GridCacheMessage> transform) {
+ txMsgTransform = transform;
+ }
+
+ /** @param callback Callback invoked on transaction commit. */
+ public void onCommitCallback(Consumer<IgniteInternalTx> callback) {
+ onCommitCallback = callback;
+ }
+
+ /**
+ * Sends transaction message after transforming it.
+ *
+ * @param nodeId Node ID to send message.
+ * @param msg Original message to transform.
+ * @param tx Transaction.
+ * @param plc IO policy.
+ */
+ public void sendTransactionMessage(UUID nodeId, GridCacheMessage msg,
IgniteInternalTx tx, byte plc) throws IgniteCheckedException {
Review Comment:
`plc` paramter always equal to `tx.ioPolicy()` and can be eliminated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
