Skip to content

Commit fc388d2

Browse files
committed
Interrupt thread instead of checking status
1 parent 0ed56bb commit fc388d2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/stream/impl/Utils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ static <T> T callAndMaybeRetry(
255255
try {
256256
Thread.sleep(delay.toMillis());
257257
} catch (InterruptedException ex) {
258-
Thread.interrupted();
258+
Thread.currentThread().interrupt();
259259
lastException = ex;
260260
keepTrying = false;
261261
}

0 commit comments

Comments
 (0)