Repository: ignite Updated Branches: refs/heads/ignite-8446 a88e872d9 -> 3a43df350
8446 Signed-off-by: Anton Vinogradov <a...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9ab5a0fe Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9ab5a0fe Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9ab5a0fe Branch: refs/heads/ignite-8446 Commit: 9ab5a0feeb468c2d4bb9cde2229038aae9eda253 Parents: a88e872 Author: Anton Vinogradov <a...@apache.org> Authored: Wed Jun 27 17:15:46 2018 +0300 Committer: Anton Vinogradov <a...@apache.org> Committed: Wed Jun 27 17:15:46 2018 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/transactions/IgniteTxAdapter.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9ab5a0fe/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java index d9eff2d..6243e05 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java @@ -1211,7 +1211,10 @@ public abstract class IgniteTxAdapter extends GridMetadataAwareAdapter implement if (!system() /* ignoring system tx */ && evtMgr.isRecordable(type)) evtMgr.record(new TransactionStateChangedEvent( - cctx.discovery().localNode(), null, type, ((GridNearTxLocal)this).rollbackOnlyProxy())); + cctx.discovery().localNode(), + null, + type, + new TransactionEventProxyImpl(xid(), ((GridNearTxLocal)this).rollbackOnlyProxy()))); } /** {@inheritDoc} */
