Skip to content

Commit ed241cb

Browse files
committed
Disable reconnect of stopped stream
1 parent f4a525f commit ed241cb

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

topic/src/main/java/tech/ydb/topic/impl/GrpcStreamRetrier.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,11 @@ private void tryScheduleReconnect() {
9292
}
9393

9494
void reconnect() {
95+
if (isStopped.get()) {
96+
getLogger().info("[{}] {} is already stopped, no need to reconnect", id, getStreamName());
97+
return;
98+
}
99+
95100
getLogger().info("[{}] {} reconnect #{} started", id, getStreamName(), reconnectCounter.get());
96101
if (!isReconnecting.compareAndSet(true, false)) {
97102
getLogger().warn("Couldn't reset reconnect flag. Shouldn't happen");

0 commit comments

Comments
 (0)