From b062ec050c9eaed18dc817030bd8cc7569c7fa51 Mon Sep 17 00:00:00 2001 From: rbygrave Date: Wed, 18 Aug 2021 09:05:28 +1200 Subject: [PATCH] #2320 - Tidy only changes --- .../src/main/java/io/ebean/redis/topic/DaemonTopicRunner.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ebean-redis/src/main/java/io/ebean/redis/topic/DaemonTopicRunner.java b/ebean-redis/src/main/java/io/ebean/redis/topic/DaemonTopicRunner.java index a95802c57..a6b682bce 100644 --- a/ebean-redis/src/main/java/io/ebean/redis/topic/DaemonTopicRunner.java +++ b/ebean-redis/src/main/java/io/ebean/redis/topic/DaemonTopicRunner.java @@ -31,8 +31,7 @@ public final class DaemonTopicRunner { } public void run() { - Thread t = new Thread(() -> attemptConnections(), "redis-sub"); - t.start(); + new Thread(this::attemptConnections, "redis-sub").start(); } private void attemptConnections() { @@ -55,6 +54,7 @@ public final class DaemonTopicRunner { // wait a little before retrying Thread.sleep(reconnectWaitMillis); } catch (InterruptedException e1) { + Thread.currentThread().interrupt(); log.warn("Interrupted redis re-connection wait", e1); } }