Repository: logging-log4j2 Updated Branches: refs/heads/GenericMapMessageSimple 2e42ea8bd -> 1801de077
Add and use StringMapMessage (all about addressing compiler warnings about raw generic types). Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/1801de07 Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/1801de07 Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/1801de07 Branch: refs/heads/GenericMapMessageSimple Commit: 1801de0779cb0daf7f170b245fbdf95f1c0b2ba7 Parents: 2e42ea8 Author: Gary Gregory <[email protected]> Authored: Sun Jun 4 19:04:38 2017 -0700 Committer: Gary Gregory <[email protected]> Committed: Sun Jun 4 19:04:38 2017 -0700 ---------------------------------------------------------------------- .../logging/log4j/message/MapMessage.java | 2 +- .../logging/log4j/message/StringMapMessage.java | 55 ++++++++++++++++++++ .../logging/log4j/message/MapMessageTest.java | 12 ++--- .../appender/mom/activemq/JmsAppenderIT.java | 4 +- .../log4j/core/appender/mom/JmsManager.java | 13 +++-- .../core/appender/rewrite/MapRewritePolicy.java | 8 +-- .../logging/log4j/core/filter/MapFilter.java | 12 ++--- .../log4j/core/layout/MessageLayout.java | 2 +- .../logging/log4j/core/lookup/MapLookup.java | 6 +-- .../log4j/core/pattern/MapPatternConverter.java | 8 +-- .../log4j/core/CollectionLoggingTest.java | 4 +- .../log4j/core/GcFreeLoggingTestUtil.java | 6 +-- .../appender/rewrite/MapRewritePolicyTest.java | 24 ++++----- .../appender/rewrite/RewriteAppenderTest.java | 6 +-- .../log4j/core/filter/MapFilterTest.java | 8 +-- .../log4j/core/lookup/MapLookupTest.java | 4 +- .../core/pattern/MapPatternConverterTest.java | 6 +-- .../log4j/flume/appender/FlumeEvent.java | 10 ++-- .../logging/log4j/lookup/CustomMapMessage.java | 4 +- .../logging/log4j/lookup/MapMessageLookup.java | 6 +-- 20 files changed, 127 insertions(+), 73 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-api/src/main/java/org/apache/logging/log4j/message/MapMessage.java ---------------------------------------------------------------------- diff --git a/log4j-api/src/main/java/org/apache/logging/log4j/message/MapMessage.java b/log4j-api/src/main/java/org/apache/logging/log4j/message/MapMessage.java index ab99608..612e5e3 100644 --- a/log4j-api/src/main/java/org/apache/logging/log4j/message/MapMessage.java +++ b/log4j-api/src/main/java/org/apache/logging/log4j/message/MapMessage.java @@ -41,7 +41,7 @@ import org.apache.logging.log4j.util.TriConsumer; * values. * </p> * <p> - * This class was pulled up from {@link MapMessage} to allow for Objects as values. + * This class was pulled up from {@link StringMapMessage} to allow for Objects as values. * </p> * @param <M> A hack to allow subclasses to use fluent APIs and override methods that return instances of subclasses. * @param <V> The value type http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-api/src/main/java/org/apache/logging/log4j/message/StringMapMessage.java ---------------------------------------------------------------------- diff --git a/log4j-api/src/main/java/org/apache/logging/log4j/message/StringMapMessage.java b/log4j-api/src/main/java/org/apache/logging/log4j/message/StringMapMessage.java new file mode 100644 index 0000000..548a612 --- /dev/null +++ b/log4j-api/src/main/java/org/apache/logging/log4j/message/StringMapMessage.java @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache license, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the license for the specific language governing permissions and + * limitations under the license. + */ + +package org.apache.logging.log4j.message; + +import java.util.Map; + +/** + * A {@link StringMapMessage} typed to {@link String}-only values. This is like the MapMessage class before 2.9. + * + * @since 2.9 + */ +public class StringMapMessage extends MapMessage<StringMapMessage, String> { + + private static final long serialVersionUID = 1L; + + /** + * Constructs a new instance. + */ + public StringMapMessage() { + super(); + } + + /** + * Constructs a new instance. + * + * @param initialCapacity the initial capacity. + */ + public StringMapMessage(final int initialCapacity) { + super(initialCapacity); + } + + /** + * Constructs a new instance based on an existing Map. + * @param map The Map. + */ + public StringMapMessage(final Map<String, String> map) { + super(map); + } + +} http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-api/src/test/java/org/apache/logging/log4j/message/MapMessageTest.java ---------------------------------------------------------------------- diff --git a/log4j-api/src/test/java/org/apache/logging/log4j/message/MapMessageTest.java b/log4j-api/src/test/java/org/apache/logging/log4j/message/MapMessageTest.java index e7bef75..1e06914 100644 --- a/log4j-api/src/test/java/org/apache/logging/log4j/message/MapMessageTest.java +++ b/log4j-api/src/test/java/org/apache/logging/log4j/message/MapMessageTest.java @@ -28,7 +28,7 @@ public class MapMessageTest { @Test public void testMap() { final String testMsg = "Test message {}"; - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("message", testMsg); msg.put("project", "Log4j"); final String result = msg.getFormattedMessage(); @@ -39,7 +39,7 @@ public class MapMessageTest { @Test public void testBuilder() { final String testMsg = "Test message {}"; - final MapMessage msg = new MapMessage() + final StringMapMessage msg = new StringMapMessage() .with("message", testMsg) .with("project", "Log4j"); final String result = msg.getFormattedMessage(); @@ -50,7 +50,7 @@ public class MapMessageTest { @Test public void testXML() { final String testMsg = "Test message {}"; - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("message", testMsg); msg.put("project", "Log4j"); final String result = msg.getFormattedMessage(new String[]{"XML"}); @@ -63,7 +63,7 @@ public class MapMessageTest { @Test public void testJSON() { final String testMsg = "Test message {}"; - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("message", testMsg); msg.put("project", "Log4j"); final String result = msg.getFormattedMessage(new String[]{"JSON"}); @@ -74,7 +74,7 @@ public class MapMessageTest { @Test public void testJava() { final String testMsg = "Test message {}"; - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("message", testMsg); msg.put("project", "Log4j"); final String result = msg.getFormattedMessage(new String[]{"Java"}); @@ -84,7 +84,7 @@ public class MapMessageTest { @Test public void testMutableByDesign() { // LOG4J2-763 - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); // modify parameter before calling msg.getFormattedMessage msg.put("key1", "value1"); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core-its/src/test/java/org/apache/logging/log4j/core/appender/mom/activemq/JmsAppenderIT.java ---------------------------------------------------------------------- diff --git a/log4j-core-its/src/test/java/org/apache/logging/log4j/core/appender/mom/activemq/JmsAppenderIT.java b/log4j-core-its/src/test/java/org/apache/logging/log4j/core/appender/mom/activemq/JmsAppenderIT.java index b0bf594..989701e 100644 --- a/log4j-core-its/src/test/java/org/apache/logging/log4j/core/appender/mom/activemq/JmsAppenderIT.java +++ b/log4j-core-its/src/test/java/org/apache/logging/log4j/core/appender/mom/activemq/JmsAppenderIT.java @@ -44,7 +44,7 @@ import org.apache.logging.log4j.core.impl.Log4jLogEvent; import org.apache.logging.log4j.core.layout.MessageLayout; import org.apache.logging.log4j.core.layout.SerializedLayout; import org.apache.logging.log4j.core.net.JndiManager; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.SimpleMessage; import org.junit.After; import org.junit.Assert; @@ -108,7 +108,7 @@ public class JmsAppenderIT { map.put("threadName", Thread.currentThread().getName()); final LogEvent event = Log4jLogEvent.newBuilder().setLoggerName(loggerName) // .setLoggerFqcn(loggerName).setLevel(Level.INFO) // - .setMessage(new MapMessage(map)) // + .setMessage(new StringMapMessage(map)) // .setTimeMillis(System.currentTimeMillis()).build(); appender.append(event); } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/JmsManager.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/JmsManager.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/JmsManager.java index cddf791..bedba18 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/JmsManager.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/mom/JmsManager.java @@ -132,20 +132,19 @@ public class JmsManager extends AbstractManager { public Message createMessage(final Serializable object) throws JMSException { if (object instanceof String) { return this.session.createTextMessage((String) object); - } - else if (object instanceof org.apache.logging.log4j.message.MapMessage) { - return map((org.apache.logging.log4j.message.MapMessage) object, this.session.createMapMessage()); + } else if (object instanceof org.apache.logging.log4j.message.MapMessage) { + return map((org.apache.logging.log4j.message.MapMessage<?, ?>) object, this.session.createMapMessage()); } return this.session.createObjectMessage(object); } - private MapMessage map(final org.apache.logging.log4j.message.MapMessage log4jMapMessage, final MapMessage jmsMapMessage) { + private MapMessage map(final org.apache.logging.log4j.message.MapMessage<?, ?> log4jMapMessage, final MapMessage jmsMapMessage) { // Map without calling rg.apache.logging.log4j.message.MapMessage#getData() which makes a copy of the map. - log4jMapMessage.forEach(new BiConsumer<String, String>() { + log4jMapMessage.forEach(new BiConsumer<String, Object>() { @Override - public void accept(final String key, final String value) { + public void accept(final String key, final Object value) { try { - jmsMapMessage.setString(key, value); + jmsMapMessage.setObject(key, value); } catch (JMSException e) { throw new IllegalArgumentException(String.format("%s mapping key '%s' to value '%s': %s", e.getClass(), key, value, e.getLocalizedMessage()), e); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicy.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicy.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicy.java index 7735424..9c315fc 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicy.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicy.java @@ -28,7 +28,7 @@ import org.apache.logging.log4j.core.config.plugins.PluginElement; import org.apache.logging.log4j.core.config.plugins.PluginFactory; import org.apache.logging.log4j.core.impl.Log4jLogEvent; import org.apache.logging.log4j.core.util.KeyValuePair; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.Message; import org.apache.logging.log4j.status.StatusLogger; @@ -60,11 +60,11 @@ public final class MapRewritePolicy implements RewritePolicy { @Override public LogEvent rewrite(final LogEvent source) { final Message msg = source.getMessage(); - if (msg == null || !(msg instanceof MapMessage)) { + if (msg == null || !(msg instanceof StringMapMessage)) { return source; } - final Map<String, String> newMap = new HashMap<>(((MapMessage) msg).getData()); + final Map<String, String> newMap = new HashMap<>(((StringMapMessage) msg).getData()); switch (mode) { case Add: { newMap.putAll(map); @@ -78,7 +78,7 @@ public final class MapRewritePolicy implements RewritePolicy { } } } - final MapMessage message = ((MapMessage) msg).newInstance(newMap); + final StringMapMessage message = ((StringMapMessage) msg).newInstance(newMap); final LogEvent result = new Log4jLogEvent.Builder(source).setMessage(message).build(); return result; } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/filter/MapFilter.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/filter/MapFilter.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/filter/MapFilter.java index c2ebc37..b91038a 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/filter/MapFilter.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/filter/MapFilter.java @@ -33,7 +33,7 @@ import org.apache.logging.log4j.core.config.plugins.PluginAttribute; import org.apache.logging.log4j.core.config.plugins.PluginElement; import org.apache.logging.log4j.core.config.plugins.PluginFactory; import org.apache.logging.log4j.core.util.KeyValuePair; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.Message; import org.apache.logging.log4j.util.BiConsumer; import org.apache.logging.log4j.util.IndexedReadOnlyStringMap; @@ -66,8 +66,8 @@ public class MapFilter extends AbstractFilter { @Override public Result filter(final Logger logger, final Level level, final Marker marker, final Message msg, final Throwable t) { - if (msg instanceof MapMessage) { - return filter((MapMessage) msg) ? onMatch : onMismatch; + if (msg instanceof StringMapMessage) { + return filter((StringMapMessage) msg) ? onMatch : onMismatch; } return Result.NEUTRAL; } @@ -75,13 +75,13 @@ public class MapFilter extends AbstractFilter { @Override public Result filter(final LogEvent event) { final Message msg = event.getMessage(); - if (msg instanceof MapMessage) { - return filter((MapMessage) msg) ? onMatch : onMismatch; + if (msg instanceof StringMapMessage) { + return filter((StringMapMessage) msg) ? onMatch : onMismatch; } return Result.NEUTRAL; } - protected boolean filter(final MapMessage mapMessage) { + protected boolean filter(final StringMapMessage mapMessage) { boolean match = false; for (int i = 0; i < map.size(); i++) { final String toMatch = mapMessage.get(map.getKeyAt(i)); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/layout/MessageLayout.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/layout/MessageLayout.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/layout/MessageLayout.java index 9adb8ee..58455ee 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/layout/MessageLayout.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/layout/MessageLayout.java @@ -28,7 +28,7 @@ import org.apache.logging.log4j.message.Message; /** * Formats a {@link LogEvent} in its {@link Message} form. * <p> - * Useful in combination with a JMS Appender to map a Log4j {@link org.apache.logging.log4j.message.MapMessage} to a JMS + * Useful in combination with a JMS Appender to map a Log4j {@link org.apache.logging.log4j.message.StringMapMessage} to a JMS * {@link javax.jms.MapMessage}. * </p> */ http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/lookup/MapLookup.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/lookup/MapLookup.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/lookup/MapLookup.java index c00645e..466decb 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/lookup/MapLookup.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/lookup/MapLookup.java @@ -22,7 +22,7 @@ import java.util.Map; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.config.plugins.Plugin; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; /** * A map-based lookup. @@ -118,7 +118,7 @@ public class MapLookup implements StrLookup { @Override public String lookup(final LogEvent event, final String key) { - final boolean isMapMessage = event != null && event.getMessage() instanceof MapMessage; + final boolean isMapMessage = event != null && event.getMessage() instanceof StringMapMessage; if (map == null && !isMapMessage) { return null; } @@ -129,7 +129,7 @@ public class MapLookup implements StrLookup { } } if (isMapMessage) { - return ((MapMessage) event.getMessage()).get(key); + return ((StringMapMessage) event.getMessage()).get(key); } return null; } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/main/java/org/apache/logging/log4j/core/pattern/MapPatternConverter.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/pattern/MapPatternConverter.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/pattern/MapPatternConverter.java index fd3c7b2..6f018bd 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/pattern/MapPatternConverter.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/pattern/MapPatternConverter.java @@ -18,7 +18,7 @@ package org.apache.logging.log4j.core.pattern; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.config.plugins.Plugin; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.util.IndexedReadOnlyStringMap; /** @@ -60,9 +60,9 @@ public final class MapPatternConverter extends LogEventPatternConverter { */ @Override public void format(final LogEvent event, final StringBuilder toAppendTo) { - MapMessage msg; - if (event.getMessage() instanceof MapMessage) { - msg = (MapMessage) event.getMessage(); + StringMapMessage msg; + if (event.getMessage() instanceof StringMapMessage) { + msg = (StringMapMessage) event.getMessage(); } else { return; } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/CollectionLoggingTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/CollectionLoggingTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/CollectionLoggingTest.java index 505bf3f..d1ca640 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/CollectionLoggingTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/CollectionLoggingTest.java @@ -24,7 +24,7 @@ import java.util.Map; import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.junit.LoggerContextRule; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.test.appender.ListAppender; import org.junit.Before; import org.junit.ClassRule; @@ -61,7 +61,7 @@ public class CollectionLoggingTest { final Map<String, String> map = new HashMap<>(); map.put("MyKey1", "MyValue1"); map.put("MyKey2", "MyValue2"); - logger.error(new MapMessage(map)); + logger.error(new StringMapMessage(map)); logger.error(map); // TODO: some assertions } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/GcFreeLoggingTestUtil.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/GcFreeLoggingTestUtil.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/GcFreeLoggingTestUtil.java index 7c4abd1..69ffe2c 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/GcFreeLoggingTestUtil.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/GcFreeLoggingTestUtil.java @@ -32,7 +32,7 @@ import org.apache.logging.log4j.Marker; import org.apache.logging.log4j.MarkerManager; import org.apache.logging.log4j.ThreadContext; import org.apache.logging.log4j.core.util.Constants; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.util.Strings; import com.google.monitoring.runtime.instrumentation.AllocationRecorder; @@ -70,7 +70,7 @@ public class GcFreeLoggingTestUtil { logger.fatal(test, "This message is logged to the console"); logger.error("Sample error message"); logger.error("Test parameterized message {}", "param"); - logger.error(new MapMessage().with("eventId", "Login")); // initialize GelfLayout's messageStringBuilder + logger.error(new StringMapMessage().with("eventId", "Login")); // initialize GelfLayout's messageStringBuilder for (int i = 0; i < 256; i++) { logger.debug("ensure all ringbuffer slots have been used once"); // allocate MutableLogEvent.messageText } @@ -105,7 +105,7 @@ public class GcFreeLoggingTestUtil { } }; Thread.sleep(500); - final MapMessage mapMessage = new MapMessage().with("eventId", "Login"); + final StringMapMessage mapMessage = new StringMapMessage().with("eventId", "Login"); AllocationRecorder.addSampler(sampler); // now do some steady-state logging http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicyTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicyTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicyTest.java index e18cb00..b834cff 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicyTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/MapRewritePolicyTest.java @@ -25,7 +25,7 @@ import org.apache.logging.log4j.MarkerManager; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.impl.Log4jLogEvent; import org.apache.logging.log4j.core.util.KeyValuePair; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.SimpleMessage; import org.apache.logging.log4j.message.StructuredDataMessage; import org.apache.logging.log4j.spi.MutableThreadContextStack; @@ -60,7 +60,7 @@ public class MapRewritePolicyTest { .setTimeMillis(2).build(); logEvent1 = ((Log4jLogEvent) logEvent0).asBuilder() // - .setMessage(new MapMessage(map)) // + .setMessage(new StringMapMessage(map)) // .setSource(new StackTraceElement("MapRewritePolicyTest", "setupClass", "MapRewritePolicyTest", 29)) // .build(); @@ -76,7 +76,7 @@ public class MapRewritePolicyTest { logEvent3 = ((Log4jLogEvent) logEvent0).asBuilder() // .setContextStack(stack) // .setLevel(Level.ALL) // - .setMessage(new MapMessage(map)) // + .setMessage(new StringMapMessage(map)) // .setTimeMillis(Long.MAX_VALUE) // .setSource(new StackTraceElement("MapRewritePolicyTest", "setupClass", "MapRewritePolicyTest", 31)) // .build(); @@ -92,15 +92,15 @@ public class MapRewritePolicyTest { rewritten = addPolicy.rewrite(logEvent1); compareLogEvents(logEvent1, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = addPolicy.rewrite(logEvent2); compareLogEvents(logEvent2, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = addPolicy.rewrite(logEvent3); compareLogEvents(logEvent3, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); } @Test @@ -112,15 +112,15 @@ public class MapRewritePolicyTest { rewritten = updatePolicy.rewrite(logEvent1); compareLogEvents(logEvent1, rewritten); - checkUpdated(((MapMessage)rewritten.getMessage()).getData()); + checkUpdated(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = updatePolicy.rewrite(logEvent2); compareLogEvents(logEvent2, rewritten); - checkUpdated(((MapMessage)rewritten.getMessage()).getData()); + checkUpdated(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = updatePolicy.rewrite(logEvent3); compareLogEvents(logEvent3, rewritten); - checkUpdated(((MapMessage)rewritten.getMessage()).getData()); + checkUpdated(((StringMapMessage)rewritten.getMessage()).getData()); } @Test @@ -132,15 +132,15 @@ public class MapRewritePolicyTest { rewritten = addPolicy.rewrite(logEvent1); compareLogEvents(logEvent1, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = addPolicy.rewrite(logEvent2); compareLogEvents(logEvent2, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); rewritten = addPolicy.rewrite(logEvent3); compareLogEvents(logEvent3, rewritten); - checkAdded(((MapMessage)rewritten.getMessage()).getData()); + checkAdded(((StringMapMessage)rewritten.getMessage()).getData()); } private void checkAdded(final Map<String, String> addedMap) { http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/RewriteAppenderTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/RewriteAppenderTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/RewriteAppenderTest.java index 1c9c9b1..339855f 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/RewriteAppenderTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/rewrite/RewriteAppenderTest.java @@ -29,7 +29,7 @@ import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.junit.LoggerContextRule; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.Message; import org.apache.logging.log4j.message.StructuredDataMessage; import org.apache.logging.log4j.test.appender.ListAppender; @@ -71,8 +71,8 @@ public class RewriteAppenderTest { assertTrue("Incorrect number of events. Expected 1, got " + list.size(), list.size() == 1); final LogEvent event = list.get(0); final Message m = event.getMessage(); - assertTrue("Message is not a MapMessage", m instanceof MapMessage); - final MapMessage message = (MapMessage) m; + assertTrue("Message is not a MapMessage", m instanceof StringMapMessage); + final StringMapMessage message = (StringMapMessage) m; final Map<String, String> map = message.getData(); assertNotNull("No Map", map); assertTrue("Incorrect number of map entries, expected 3 got " + map.size(), map.size() == 3); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/filter/MapFilterTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/filter/MapFilterTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/filter/MapFilterTest.java index 61006cb..7310d38 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/filter/MapFilterTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/filter/MapFilterTest.java @@ -27,7 +27,7 @@ import org.apache.logging.log4j.core.Filter; import org.apache.logging.log4j.core.config.Configuration; import org.apache.logging.log4j.core.util.KeyValuePair; import org.apache.logging.log4j.junit.LoggerContextRule; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.test.appender.ListAppender; import org.junit.ClassRule; import org.junit.Test; @@ -48,7 +48,7 @@ public class MapFilterTest { new KeyValuePair("ToAccount", "123456")}; MapFilter filter = MapFilter.createFilter(pairs, "and", null, null); filter.start(); - MapMessage msg = new MapMessage(); + StringMapMessage msg = new StringMapMessage(); msg.put("ToAccount", "123456"); msg.put("FromAccount", "211000"); msg.put("Amount", "1000.00"); @@ -58,7 +58,7 @@ public class MapFilterTest { assertSame(Filter.Result.DENY, filter.filter(null, Level.ERROR, null, msg, null)); filter = MapFilter.createFilter(pairs, "or", null, null); filter.start(); - msg = new MapMessage(); + msg = new StringMapMessage(); msg.put("ToAccount", "123456"); msg.put("FromAccount", "211000"); msg.put("Amount", "1000.00"); @@ -85,7 +85,7 @@ public class MapFilterTest { final Logger logger = LogManager.getLogger(MapFilterTest.class); final Map<String, String> eventMap = new HashMap<>(); eventMap.put("eventId", "Login"); - logger.debug(new MapMessage(eventMap)); + logger.debug(new StringMapMessage(eventMap)); final ListAppender app = context.getListAppender("LIST"); final List<String> msgs = app.getMessages(); assertNotNull("No messages", msgs); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/lookup/MapLookupTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/lookup/MapLookupTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/lookup/MapLookupTest.java index 313b527..61d81ec 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/lookup/MapLookupTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/lookup/MapLookupTest.java @@ -22,7 +22,7 @@ import java.util.HashMap; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.impl.Log4jLogEvent; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.junit.Test; /** @@ -73,7 +73,7 @@ public class MapLookupTest { map.put("A", "B"); final HashMap<String, String> eventMap = new HashMap<>(); eventMap.put("A1", "B1"); - final MapMessage message = new MapMessage(eventMap); + final StringMapMessage message = new StringMapMessage(eventMap); final LogEvent event = Log4jLogEvent.newBuilder() .setMessage(message) .build(); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-core/src/test/java/org/apache/logging/log4j/core/pattern/MapPatternConverterTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/pattern/MapPatternConverterTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/pattern/MapPatternConverterTest.java index 23ebd36..811924a 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/pattern/MapPatternConverterTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/pattern/MapPatternConverterTest.java @@ -19,7 +19,7 @@ package org.apache.logging.log4j.core.pattern; import org.apache.logging.log4j.Level; import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.impl.Log4jLogEvent; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.junit.Test; import static org.junit.Assert.*; @@ -32,7 +32,7 @@ public class MapPatternConverterTest { @Test public void testConverter() { - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("subject", "I"); msg.put("verb", "love"); msg.put("object", "Log4j"); @@ -58,7 +58,7 @@ public class MapPatternConverterTest { @Test public void testConverterWithKey() { - final MapMessage msg = new MapMessage(); + final StringMapMessage msg = new StringMapMessage(); msg.put("subject", "I"); msg.put("verb", "love"); msg.put("object", "Log4j"); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java ---------------------------------------------------------------------- diff --git a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java index a1059df..56c0444 100644 --- a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java +++ b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java @@ -35,7 +35,7 @@ import org.apache.logging.log4j.core.impl.Log4jLogEvent; import org.apache.logging.log4j.core.impl.ThrowableProxy; import org.apache.logging.log4j.core.util.Patterns; import org.apache.logging.log4j.core.util.UuidUtil; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.Message; import org.apache.logging.log4j.message.StructuredDataId; import org.apache.logging.log4j.message.StructuredDataMessage; @@ -131,13 +131,13 @@ public class FlumeEvent extends SimpleEvent implements LogEvent { } final String guid = UuidUtil.getTimeBasedUuid().toString(); final Message message = event.getMessage(); - if (message instanceof MapMessage) { + if (message instanceof StringMapMessage) { // Add the guid to the Map so that it can be included in the Layout. - ((MapMessage) message).put(GUID, guid); + ((StringMapMessage) message).put(GUID, guid); if (message instanceof StructuredDataMessage) { addStructuredData(eventPrefix, headers, (StructuredDataMessage) message); } - addMapData(eventPrefix, headers, (MapMessage) message); + addMapData(eventPrefix, headers, (StringMapMessage) message); } else { headers.put(GUID, guid); } @@ -152,7 +152,7 @@ public class FlumeEvent extends SimpleEvent implements LogEvent { fields.put(prefix + EVENT_ID, id.getName()); } - protected void addMapData(final String prefix, final Map<String, String> fields, final MapMessage msg) { + protected void addMapData(final String prefix, final Map<String, String> fields, final StringMapMessage msg) { final Map<String, String> data = msg.getData(); for (final Map.Entry<String, String> entry : data.entrySet()) { fields.put(prefix + entry.getKey(), entry.getValue()); http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/CustomMapMessage.java ---------------------------------------------------------------------- diff --git a/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/CustomMapMessage.java b/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/CustomMapMessage.java index dabd91e..06f78f4 100644 --- a/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/CustomMapMessage.java +++ b/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/CustomMapMessage.java @@ -17,7 +17,7 @@ package org.apache.logging.log4j.lookup; import org.apache.logging.log4j.message.AsynchronouslyFormattable; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import java.util.Map; @@ -25,7 +25,7 @@ import java.util.Map; * */ @AsynchronouslyFormattable -public class CustomMapMessage extends MapMessage { +public class CustomMapMessage extends StringMapMessage { private static final long serialVersionUID = 1L; private final String message; http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/1801de07/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/MapMessageLookup.java ---------------------------------------------------------------------- diff --git a/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/MapMessageLookup.java b/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/MapMessageLookup.java index 0bcd0dd..1184382 100644 --- a/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/MapMessageLookup.java +++ b/log4j-samples/loggerProperties/src/main/java/org/apache/logging/log4j/lookup/MapMessageLookup.java @@ -23,7 +23,7 @@ import org.apache.logging.log4j.core.LogEvent; import org.apache.logging.log4j.core.config.plugins.Plugin; import org.apache.logging.log4j.core.lookup.AbstractLookup; import org.apache.logging.log4j.core.lookup.StrLookup; -import org.apache.logging.log4j.message.MapMessage; +import org.apache.logging.log4j.message.StringMapMessage; import org.apache.logging.log4j.message.Message; import org.apache.logging.log4j.status.StatusLogger; @@ -52,9 +52,9 @@ public class MapMessageLookup extends AbstractLookup { @Override public String lookup(final LogEvent event, final String key) { final Message msg = event.getMessage(); - if (msg instanceof MapMessage) { + if (msg instanceof StringMapMessage) { try { - final Map<String, String> properties = ((MapMessage) msg).getData(); + final Map<String, String> properties = ((StringMapMessage) msg).getData(); if (properties == null) { return ""; }
