airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject airavata git commit: [AIRAVATA-2126] use formatted log message from ILoggingEvent
Date Sun, 02 Oct 2016 04:25:51 GMT
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 <lahiru@apache.org>
Authored: Sat Oct 1 21:22:17 2016 -0700
Committer: Lahiru Ginnaliya Gamathige <lahiru@apache.org>
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)));


Mime
View raw message