[sling-org-apache-sling-distribution-journal-kafka] branch master updated: Do not send event when interrupted.

[cschneider]

This is an automated email from the ASF dual-hosted git repository.

cschneider pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal-kafka.git


The following commit(s) were added to refs/heads/master by this push:
     new de8f6e4  Do not send event when interrupted.
de8f6e4 is described below

commit de8f6e41fbe633dce801be476f6b265a1fa0e96e
Author: Christian Schneider <cschn...@adobe.com>
AuthorDate: Mon Jun 15 11:07:04 2020 +0200

    Do not send event when interrupted.
---
 .../org/apache/sling/distribution/journal/kafka/KafkaMessageSender.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 @@ public class KafkaMessageSender<T extends GeneratedMessage> 
implements MessageSe
             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);
         }