commit de8f6e41fbe633dce801be476f6b265a1fa0e96e
author Christian Schneider <cschneid@adobe.com> Mon Jun 15 11:07:04 2020 +0200
committer Christian Schneider <cschneid@adobe.com> Mon Jun 15 11:07:04 2020 +0200
tree 8bbf6a83b4dfa21792f03f3fdc9e66b9e733c1ed
parent e56e3ff916e0fe433f540abc2992a25e7d5e8539

Do not send event when interrupted.

src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java

diff --git a/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java b/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
index e3a434d..70e5a6a 100644
--- a/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
+++ b/src/main/java/org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java
@@ -67,7 +67,7 @@
             LOG.debug("Sent to {}", metadata);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            handleException(topic, e);
+            throw new MessagingException(format("Interrupted while trying to send to topic %s", topic), e);
         } catch (Exception e) {
             handleException(topic, e);
         }