diff --git a/enterprise/causal-clustering/src/test/java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java b/enterprise/causal-clustering/src/test/java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java
index 0ff011dfe8eb..5c32bbe5c71f 100644
--- a/enterprise/causal-clustering/src/test/java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java
+++ b/enterprise/causal-clustering/src/test/java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java
@@ -38,7 +38,8 @@ public void shouldEncodeAndDecodePullRequestMessage()
 
         // when
         channel.writeOutbound( sent );
-        channel.writeInbound( channel.readOutbound() );
+        Object message = channel.readOutbound();
+        channel.writeInbound( message );
 
         // then
         TxStreamFinishedResponse received = channel.readInbound();