diff --git a/src/Adaptive.Cluster/Client/EgressAdapter.cs b/src/Adaptive.Cluster/Client/EgressAdapter.cs
index e751fc81..779bb524 100644
--- a/src/Adaptive.Cluster/Client/EgressAdapter.cs
+++ b/src/Adaptive.Cluster/Client/EgressAdapter.cs
@@ -158,7 +158,7 @@ public void OnFragment(IDirectBuffer buffer, int offset, int length, Header head
                     {
                         _listener.OnNewLeader(
                             sessionId,
-                            _sessionEventDecoder.LeadershipTermId(),
+                            _newLeaderEventDecoder.LeadershipTermId(),
                             _newLeaderEventDecoder.LeaderMemberId(),
                             _newLeaderEventDecoder.IngressEndpoints());
                     }