[Java] Remove session id from response channel when replaying via res…

…ponse channels.
real-logic · Nov 1, 2024 · 21d5db0 · 21d5db0
1 parent c4d6a60
commit 21d5db0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/aeron-archive/src/main/java/io/aeron/archive/client/AeronArchive.java b/aeron-archive/src/main/java/io/aeron/archive/client/AeronArchive.java
@@ -3956,6 +3956,7 @@ private Subscription replayViaResponseChannel(
         replayParams.replayToken(replayToken);
         final Subscription replaySubscription = aeron.addSubscription(replayChannel, replayStreamId);
         final ChannelUriStringBuilder uriBuilder = new ChannelUriStringBuilder(context.controlRequestChannel())
+            .sessionId((Integer)null)
             .responseCorrelationId(replaySubscription.registrationId())
             .termId((Integer)null).initialTermId((Integer)null).termOffset((Integer)null)
             .termLength(64 * 1024)
@@ -4025,6 +4026,7 @@ private long startReplayViaResponseChannel(
 
         replayParams.replayToken(replayToken);
         final ChannelUriStringBuilder uriBuilder = new ChannelUriStringBuilder(context.controlRequestChannel())
+            .sessionId((Integer)null)
             .responseCorrelationId(replayParams.subscriptionRegistrationId())
             .termId((Integer)null).initialTermId((Integer)null).termOffset((Integer)null)
             .termLength(64 * 1024)