diff --git a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/catchup/tx/TxPollingClient.java b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/catchup/tx/TxPollingClient.java
index 1adaf32040de9..b47980761883d 100644
--- a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/catchup/tx/TxPollingClient.java
+++ b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/catchup/tx/TxPollingClient.java
@@ -102,8 +102,9 @@ private synchronized void onTimeout()
         try
         {
             transactionServer = connectionStrategy.coreMember();
-            pullRequestMonitor.txPullRequest( applier.lastAppliedTxId() );
-            TxPullRequest txPullRequest = new TxPullRequest( applier.lastAppliedTxId(), localDatabase.get() );
+            long lastAppliedTxId = applier.lastAppliedTxId();
+            pullRequestMonitor.txPullRequest( lastAppliedTxId );
+            TxPullRequest txPullRequest = new TxPullRequest( lastAppliedTxId, localDatabase.get() );
             catchUpClient.makeBlockingRequest( transactionServer, txPullRequest, 30, TimeUnit.SECONDS,
                     new CatchUpResponseAdaptor<Long>() {
                         @Override
diff --git a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/catchup/tx/TxPollingClientTest.java b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/catchup/tx/TxPollingClientTest.java
index 2a9ae95c3fdcf..2d91598b70210 100644
--- a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/catchup/tx/TxPollingClientTest.java
+++ b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/catchup/tx/TxPollingClientTest.java
@@ -63,7 +63,7 @@ public class TxPollingClientTest
 
     private final TxPollingClient txPuller = new TxPollingClient( NullLogProvider.getInstance(), () -> storeId,
             catchUpClient, serverSelection,
-            timeoutService, txPullTimeoutMillis, txApplier, mock(Monitors.class) );
+            timeoutService, txPullTimeoutMillis, txApplier, new Monitors() );
 
     @Before
     public void before() throws Throwable