From cd7bb273ec2d741acc9233608bb32c2bb8ca1ead Mon Sep 17 00:00:00 2001 From: scwlkq Date: Tue, 23 Jan 2024 21:32:49 +0800 Subject: [PATCH] Enhance thread handling of InterruptedException --- .../eventmesh/webhook/receive/storage/WebhookFileListener.java | 1 + 1 file changed, 1 insertion(+) diff --git a/eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/WebhookFileListener.java b/eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/WebhookFileListener.java index 8d42c9f199..e5af8501b5 100644 --- a/eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/WebhookFileListener.java +++ b/eventmesh-webhook/eventmesh-webhook-receive/src/main/java/org/apache/eventmesh/webhook/receive/storage/WebhookFileListener.java @@ -149,6 +149,7 @@ private void fileWatchRegister() { key = service.take(); } catch (InterruptedException e) { log.error("Interrupted", e); + Thread.currentThread().interrupt(); } assert key != null;