diff --git a/src/main/java/xqa/IngestBalancer.java b/src/main/java/xqa/IngestBalancer.java index da1a982..1b0c836 100644 --- a/src/main/java/xqa/IngestBalancer.java +++ b/src/main/java/xqa/IngestBalancer.java @@ -56,7 +56,10 @@ public static void main(final String... args) { ingestBalancer.processCommandLine(args); ingestBalancer.start(); ingestBalancer.join(); - } catch (InterruptedException | ParseException exception) { + } catch (InterruptedException exception) { + logger.error(exception.getMessage()); + Thread.currentThread().interrupt(); + } catch (ParseException exception) { logger.error(exception.getMessage()); } }