Repository: airavata Updated Branches: refs/heads/develop 8eea17fb9 -> e317d77fa
[AIRAVATA-2126] use formatted log message from ILoggingEvent Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/e317d77f Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/e317d77f Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/e317d77f Branch: refs/heads/develop Commit: e317d77fadc304daae16507cf6443054324e39b4 Parents: 8eea17f Author: Lahiru Ginnaliya Gamathige <[email protected]> Authored: Sat Oct 1 21:22:17 2016 -0700 Committer: Lahiru Ginnaliya Gamathige <[email protected]> Committed: Sat Oct 1 21:22:17 2016 -0700 ---------------------------------------------------------------------- .../org/apache/airavata/common/logging/kafka/KafkaAppender.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/e317d77f/modules/commons/src/main/java/org/apache/airavata/common/logging/kafka/KafkaAppender.java ---------------------------------------------------------------------- diff --git a/modules/commons/src/main/java/org/apache/airavata/common/logging/kafka/KafkaAppender.java b/modules/commons/src/main/java/org/apache/airavata/common/logging/kafka/KafkaAppender.java index 0617bcf..e20c0e0 100644 --- a/modules/commons/src/main/java/org/apache/airavata/common/logging/kafka/KafkaAppender.java +++ b/modules/commons/src/main/java/org/apache/airavata/common/logging/kafka/KafkaAppender.java @@ -84,12 +84,12 @@ public class KafkaAppender extends UnsynchronizedAppenderBase<ILoggingEvent> { !event.getLevel().equals(Level.OFF)) { final IThrowableProxy throwableProxy = event.getThrowableProxy(); final LogEntry entry = throwableProxy != null ? - new LogEntry(serverId, event.getMessage(), Instant.ofEpochMilli(event.getTimeStamp()).toString(), + new LogEntry(serverId, event.getFormattedMessage(), Instant.ofEpochMilli(event.getTimeStamp()).toString(), event.getLevel().toString(), event.getLoggerName(), event.getMDCPropertyMap(), event.getThreadName() != null ? event.getThreadName() : null, new Exception(throwableProxy.getMessage(), toStringArray(throwableProxy.getStackTraceElementProxyArray()) , throwableProxy.getClassName())) - : new LogEntry(serverId, event.getMessage(), Instant.ofEpochMilli(event.getTimeStamp()).toString(), + : new LogEntry(serverId, event.getFormattedMessage(), Instant.ofEpochMilli(event.getTimeStamp()).toString(), event.getLevel().toString(), event.getLoggerName(), event.getMDCPropertyMap(), event.getThreadName() != null ? event.getThreadName() : null); producer.send(new ProducerRecord<>(kafkaTopic, new Gson().toJson(entry)));
