Skip to content

Commit

Permalink
[Java] Naming.
Browse files Browse the repository at this point in the history
  • Loading branch information
mjpt777 committed Nov 20, 2023
1 parent 351e798 commit be772c6
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1164,7 +1164,7 @@ long prepareForNewLeadership(final long logPosition, final long nowNs)
liveLogDestination = null;
}

final long logSubRegId = logAdapter.disconnect(ctx.countedErrorHandler());
final long logSubscriptionRegistrationId = logAdapter.disconnect(ctx.countedErrorHandler());
logPublisher.disconnect(ctx.countedErrorHandler());
ClusterControl.ToggleState.deactivate(controlToggle);

Expand All @@ -1191,9 +1191,9 @@ long prepareForNewLeadership(final long logPosition, final long nowNs)
}
}

if (NULL_VALUE != logSubRegId)
if (NULL_VALUE != logSubscriptionRegistrationId)
{
awaitLocalSocketsClosed(logSubRegId);
awaitLocalSocketsClosed(logSubscriptionRegistrationId);
}

return lastAppendPosition;
Expand Down

0 comments on commit be772c6

Please sign in to comment.