You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by mi...@apache.org on 2017/01/18 19:42:52 UTC
[13/15] logging-log4j2 git commit: LOG4J2-1748 and LOG4J2-1780
Restore interrupted flag on thread
LOG4J2-1748 and LOG4J2-1780 Restore interrupted flag on thread
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/571fb8df
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/571fb8df
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/571fb8df
Branch: refs/heads/master
Commit: 571fb8df680b0db94ad1b6afed478e915b3411a3
Parents: 527b125
Author: Mikael St�ldal <mi...@magine.com>
Authored: Wed Jan 18 17:40:18 2017 +0100
Committer: Mikael St�ldal <mi...@magine.com>
Committed: Wed Jan 18 17:40:18 2017 +0100
----------------------------------------------------------------------
.../apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/571fb8df/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
index b293f2a..cb05769 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaManager.java
@@ -87,6 +87,7 @@ public class KafkaManager extends AbstractManager {
try {
closeThread.join(timeUnit.toMillis(timeout));
} catch (final InterruptedException ignore) {
+ Thread.currentThread().interrupt();
// ignore
}
}