Skip to content

Commit d035a84

Browse files
committed
IGNITE-24963 Merge with main
1 parent 8ce4a47 commit d035a84

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,9 @@ public class TxManagerImpl implements TxManager, SystemViewProvider {
187187
/** Detector of transactions that lost the coordinator. */
188188
private final OrphanDetector orphanDetector;
189189

190+
/** Topology service. */
191+
private final TopologyService topologyService;
192+
190193
/** Local node. */
191194
private final InternalClusterNode localNode;
192195

@@ -352,6 +355,7 @@ public TxManagerImpl(
352355
this.transactionIdGenerator = transactionIdGenerator;
353356
this.placementDriver = placementDriver;
354357
this.idleSafeTimePropagationPeriodMsSupplier = idleSafeTimePropagationPeriodMsSupplier;
358+
this.topologyService = topologyService;
355359
this.localNode = localNode;
356360
this.messagingService = messagingService;
357361
this.primaryReplicaExpiredListener = this::primaryReplicaExpiredListener;
@@ -1059,7 +1063,7 @@ public void failAction(UUID owner) {
10591063
// TODO https://issues.apache.org/jira/browse/IGNITE-23539
10601064
lockManager.start(deadlockPreventionPolicy);
10611065

1062-
messagingService.addMessageHandler(ReplicaMessageGroup.class, this);
1066+
messagingService.addMessageHandler(ReplicaMessageGroup.class, this::handleReplicaAsyncResponse);
10631067

10641068
persistentTxStateVacuumizer = new PersistentTxStateVacuumizer(
10651069
replicaService,

0 commit comments

Comments
 (0)