diff --git a/README.md b/README.md
index 3858fb3..b0e8129 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@ Maven:
com.wikia
dropwizard-logstash-encoder
- 1.0.2
+ 1.0.3-SNAPSHOT
```
diff --git a/pom.xml b/pom.xml
index 8e79d7e..d83ffce 100644
--- a/pom.xml
+++ b/pom.xml
@@ -5,13 +5,17 @@
com.wikia
dropwizard-logstash-encoder
- 1.0.2
+ 1.0.3-SNAPSHOT
dropwizard-logstash-encoder
Addon for dropwizard to log using the logback-logstash-encoder (see https://github.com/logstash/logstash-logback-encoder)
- https://github.com/Wikia/dropwizard-logback-logsash-encoder
+
+
+ github
+
+
Eclipse Public License
@@ -19,40 +23,55 @@
-
- scm:git:git://github.com/Wikia/dropwizard-logstash-encoder.git
- scm:git:ssh://git@github.com/Wikia/dropwizard-logstash-encoder.git
- https://github.com/Wikia/dropwizard-logstash-encoder
-
-
-
-
- Nelson Monterroso
- http://github.com/nmonterroso
- nelson@wikia-inc.com
-
-
-
-
- ossrh
- https://oss.sonatype.org/content/repositories/snapshots
-
- ossrh
- https://oss.sonatype.org/service/local/staging/deploy/maven2/
+ internal.repo
+ Temporary Staging Repository
+ file://${project.build.directory}/mvn-repo
-
+
+
+ maven-deploy-plugin
+ 2.8.1
+
+ internal.repo::default::file://${project.build.directory}/mvn-repo
+
+
+
+ com.github.github
+ site-maven-plugin
+ 0.11
+
+ Maven artifacts for ${project.version}
+ true
+ ${project.build.directory}/mvn-repo
+ refs/heads/mvn-repo
+ **/*
+ true
+ dropwizard-logstash-encoder
+ sociable
+
+
+
+
+
+ site
+
+ deploy
+
+
+
+
org.apache.maven.plugins
maven-compiler-plugin
3.2
- 1.8
- 1.8
+ 1.7
+ 1.7
@@ -81,31 +100,6 @@
-
- org.apache.maven.plugins
- maven-gpg-plugin
- 1.5
-
-
- sign-artifacts
- verify
-
- sign
-
-
-
-
-
- org.sonatype.plugins
- nexus-staging-maven-plugin
- 1.6.3
- true
-
- ossrh
- https://oss.sonatype.org/
- true
-
-
diff --git a/src/main/java/com/wikia/dropwizard/logstash/appender/LogstashAppenderFactoryHelper.java b/src/main/java/com/wikia/dropwizard/logstash/appender/LogstashAppenderFactoryHelper.java
index f35c489..c7f31c1 100644
--- a/src/main/java/com/wikia/dropwizard/logstash/appender/LogstashAppenderFactoryHelper.java
+++ b/src/main/java/com/wikia/dropwizard/logstash/appender/LogstashAppenderFactoryHelper.java
@@ -1,32 +1,39 @@
package com.wikia.dropwizard.logstash.appender;
import com.fasterxml.jackson.databind.ObjectMapper;
+
import net.logstash.logback.fieldnames.LogstashFieldNames;
import java.io.IOException;
import java.io.StringWriter;
import java.util.HashMap;
+import java.util.Map;
public class LogstashAppenderFactoryHelper {
+
+ private static String getOrDefault(Map map, String key, String defaultValue) {
+ return map.containsKey(key) ? map.get(key) : defaultValue;
+ }
+
public static LogstashFieldNames getFieldNamesFromHashMap(HashMap map) {
LogstashFieldNames fieldNames = new LogstashFieldNames();
- fieldNames.setTimestamp(map.getOrDefault("timestamp", "@timestamp"));
- fieldNames.setVersion(map.getOrDefault("version", "@version"));
- fieldNames.setMessage(map.getOrDefault("message", "message"));
- fieldNames.setLogger(map.getOrDefault("logger", "logger_name"));
- fieldNames.setThread(map.getOrDefault("thread", "thread_name"));
- fieldNames.setLevel(map.getOrDefault("level", "level"));
- fieldNames.setLevelValue(map.getOrDefault("levelValue", "level_value"));
- fieldNames.setCaller(map.getOrDefault("caller", null));
- fieldNames.setCallerClass(map.getOrDefault("callerClass", "caller_class_name"));
- fieldNames.setCallerMethod(map.getOrDefault("callerMethod", "caller_method_name"));
- fieldNames.setCallerFile(map.getOrDefault("callerFile", "caller_file_name"));
- fieldNames.setCallerLine(map.getOrDefault("callerLine", "caller_line_number"));
- fieldNames.setStackTrace(map.getOrDefault("stackTrace", "stack_trace"));
- fieldNames.setTags(map.getOrDefault("tags", "tags"));
- fieldNames.setMdc(map.getOrDefault("mdc", null));
- fieldNames.setContext(map.getOrDefault("context", null));
+ fieldNames.setTimestamp(getOrDefault(map, "timestamp", "@timestamp"));
+ fieldNames.setVersion(getOrDefault(map, "version", "@version"));
+ fieldNames.setMessage(getOrDefault(map, "message", "message"));
+ fieldNames.setLogger(getOrDefault(map, "logger", "logger_name"));
+ fieldNames.setThread(getOrDefault(map, "thread", "thread_name"));
+ fieldNames.setLevel(getOrDefault(map, "level", "level"));
+ fieldNames.setLevelValue(getOrDefault(map, "levelValue", "level_value"));
+ fieldNames.setCaller(getOrDefault(map, "caller", null));
+ fieldNames.setCallerClass(getOrDefault(map, "callerClass", "caller_class_name"));
+ fieldNames.setCallerMethod(getOrDefault(map, "callerMethod", "caller_method_name"));
+ fieldNames.setCallerFile(getOrDefault(map, "callerFile", "caller_file_name"));
+ fieldNames.setCallerLine(getOrDefault(map, "callerLine", "caller_line_number"));
+ fieldNames.setStackTrace(getOrDefault(map, "stackTrace", "stack_trace"));
+ fieldNames.setTags(getOrDefault(map, "tags", "tags"));
+ fieldNames.setMdc(getOrDefault(map, "mdc", null));
+ fieldNames.setContext(getOrDefault(map, "context", null));
return fieldNames;
}