From d0c619a0ad084433514d9b36ddf679b55db91c9b Mon Sep 17 00:00:00 2001
From: shreyashthakare <shreyashthakare@192.168.0.104>
Date: Tue, 17 Jul 2018 00:32:13 +0530
Subject: [PATCH 1/8] BAEL-1960: Custom appender for log4j

---
 logging-modules/log4j2/pom.xml                | 219 +++++++++---------
 .../logging/log4j2/appender/MapAppender.java  |  58 +++++
 .../appender/MapAppenderIntegrationTest.java  |  35 +++
 .../log4j2/src/test/resources/log4j2.xml      | 174 +++++++-------
 4 files changed, 297 insertions(+), 189 deletions(-)
 create mode 100644 logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
 create mode 100644 logging-modules/log4j2/src/test/java/com/baeldung/logging/log4j2/appender/MapAppenderIntegrationTest.java

diff --git a/logging-modules/log4j2/pom.xml b/logging-modules/log4j2/pom.xml
index 89d37e789c..b577931f0f 100644
--- a/logging-modules/log4j2/pom.xml
+++ b/logging-modules/log4j2/pom.xml
@@ -1,117 +1,126 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <artifactId>log4j2</artifactId>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<artifactId>log4j2</artifactId>
 
-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-modules</artifactId>
-        <version>1.0.0-SNAPSHOT</version>
-        <relativePath>../../</relativePath>
-    </parent>
+	<parent>
+		<groupId>com.baeldung</groupId>
+		<artifactId>parent-modules</artifactId>
+		<version>1.0.0-SNAPSHOT</version>
+		<relativePath>../../</relativePath>
+	</parent>
 
-    <dependencies>
-        <!-- This is the needed core component. -->
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j-core.version}</version>
-        </dependency>
+	<dependencies>
+		<!-- This is the needed core component. -->
+		<dependency>
+			<groupId>org.apache.logging.log4j</groupId>
+			<artifactId>log4j-core</artifactId>
+			<version>${log4j-core.version}</version>
+		</dependency>
 
-        <!-- This is used by JSONLayout. -->
-        <dependency>
-            <groupId>com.fasterxml.jackson.core</groupId>
-            <artifactId>jackson-databind</artifactId>
-            <version>${jackson.version}</version>
-        </dependency>
+		<!-- This is the needed API component. -->
+		<dependency>
+			<groupId>org.apache.logging.log4j</groupId>
+			<artifactId>log4j-api</artifactId>
+			<version>${log4j-core.version}</version>
+		</dependency>
 
-        <!-- This is used by XMLLayout. -->
-        <dependency>
-            <groupId>com.fasterxml.jackson.dataformat</groupId>
-            <artifactId>jackson-dataformat-xml</artifactId>
-            <version>${jackson.version}</version>
-        </dependency>
 
-        <!-- This is used by JDBC Appender. -->
-        <dependency>
-            <groupId>com.h2database</groupId>
-            <artifactId>h2</artifactId>
-            <version>${h2.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.commons</groupId>
-            <artifactId>commons-dbcp2</artifactId>
-            <version>${commons-dbcp2.version}</version>
-        </dependency>
+		<!-- This is used by JSONLayout. -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>${jackson.version}</version>
+		</dependency>
 
-        <!-- This is used for testing only. -->
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j-core.version}</version>
-            <type>test-jar</type>
-            <scope>test</scope>
-        </dependency>
-    </dependencies>
+		<!-- This is used by XMLLayout. -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.dataformat</groupId>
+			<artifactId>jackson-dataformat-xml</artifactId>
+			<version>${jackson.version}</version>
+		</dependency>
 
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>${maven-compiler-plugin.version}</version>
-                <configuration>
-                    <proc>none</proc>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
+		<!-- This is used by JDBC Appender. -->
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<version>${h2.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-dbcp2</artifactId>
+			<version>${commons-dbcp2.version}</version>
+		</dependency>
 
-    <profiles>
-        <profile>
-            <id>integration</id>
-            <build>
-                <plugins>
-                    <plugin>
-                        <groupId>org.apache.maven.plugins</groupId>
-                        <artifactId>maven-surefire-plugin</artifactId>
-                        <executions>
-                            <execution>
-                                <phase>integration-test</phase>
-                                <goals>
-                                    <goal>test</goal>
-                                </goals>
-                                <configuration>
-                                    <excludes>
-                                        <exclude>**/*ManualTest.java</exclude>
-                                        <exclude>**/*LiveTest.java</exclude>
-                                    </excludes>
-                                    <includes>
-                                        <include>**/*IntegrationTest.java</include>
-                                        <include>**/*IntTest.java</include>
-                                    </includes>
-                                </configuration>
-                            </execution>
-                        </executions>
-                        <configuration>
-                            <systemPropertyVariables>
-                                <test.mime>json</test.mime>
-                                <logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
-                            </systemPropertyVariables>
-                        </configuration>
-                    </plugin>
-                </plugins>
-            </build>
-        </profile>
-    </profiles>
+		<!-- This is used for testing only. -->
+		<dependency>
+			<groupId>org.apache.logging.log4j</groupId>
+			<artifactId>log4j-core</artifactId>
+			<version>${log4j-core.version}</version>
+			<type>test-jar</type>
+			<scope>test</scope>
+		</dependency>
+	</dependencies>
 
-    <properties>
-        <jackson.version>2.9.5</jackson.version>
-        <h2.version>1.4.193</h2.version>
-        <commons-dbcp2.version>2.1.1</commons-dbcp2.version>
-        <log4j-core.version>2.11.0</log4j-core.version>
-        <maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
-    </properties>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>${maven-compiler-plugin.version}</version>
+				<configuration>
+					<proc>none</proc>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+	<profiles>
+		<profile>
+			<id>integration</id>
+			<build>
+				<plugins>
+					<plugin>
+						<groupId>org.apache.maven.plugins</groupId>
+						<artifactId>maven-surefire-plugin</artifactId>
+						<executions>
+							<execution>
+								<phase>integration-test</phase>
+								<goals>
+									<goal>test</goal>
+								</goals>
+								<configuration>
+									<excludes>
+										<exclude>**/*ManualTest.java</exclude>
+										<exclude>**/*LiveTest.java</exclude>
+									</excludes>
+									<includes>
+										<include>**/*IntegrationTest.java</include>
+										<include>**/*IntTest.java</include>
+									</includes>
+								</configuration>
+							</execution>
+						</executions>
+						<configuration>
+							<systemPropertyVariables>
+								<test.mime>json</test.mime>
+								<logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
+							</systemPropertyVariables>
+						</configuration>
+					</plugin>
+				</plugins>
+			</build>
+		</profile>
+	</profiles>
+
+	<properties>
+		<jackson.version>2.9.5</jackson.version>
+		<h2.version>1.4.193</h2.version>
+		<commons-dbcp2.version>2.1.1</commons-dbcp2.version>
+		<log4j-core.version>2.11.0</log4j-core.version>
+		<maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
+	</properties>
 
 </project>
diff --git a/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
new file mode 100644
index 0000000000..160ba58395
--- /dev/null
+++ b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
@@ -0,0 +1,58 @@
+/**
+ * 
+ */
+package com.baeldung.logging.log4j2.appender;
+
+import java.io.Serializable;
+import java.time.Instant;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+
+import org.apache.logging.log4j.core.Appender;
+import org.apache.logging.log4j.core.Core;
+import org.apache.logging.log4j.core.Filter;
+import org.apache.logging.log4j.core.Layout;
+import org.apache.logging.log4j.core.LogEvent;
+import org.apache.logging.log4j.core.appender.AbstractAppender;
+import org.apache.logging.log4j.core.config.plugins.Plugin;
+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.layout.PatternLayout;
+
+@Plugin(name = "MapAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = true)
+public class MapAppender extends AbstractAppender {
+
+    private ConcurrentMap<String, LogEvent> eventMap = new ConcurrentHashMap<>();
+
+    protected MapAppender(String name, Filter filter, Layout<? extends Serializable> layout) {
+        super(name, filter, layout);
+    }
+
+    @PluginFactory
+    public static MapAppender createAppender(@PluginAttribute("name") String name, @PluginElement("Layout") Layout<? extends Serializable> layout, @PluginElement("Filter") final Filter filter) {
+        if (name == null) {
+            LOGGER.error("No name provided for MapAppender");
+            return null;
+        }
+        if (layout == null) {
+            layout = PatternLayout.createDefaultLayout();
+        }
+        return new MapAppender(name, filter, layout);
+    }
+
+    @Override
+    public void append(LogEvent event) {
+        eventMap.put(Instant.now()
+            .toString(), event);
+    }
+
+    public ConcurrentMap<String, LogEvent> getEventMap() {
+        return eventMap;
+    }
+
+    public void setEventMap(ConcurrentMap<String, LogEvent> eventMap) {
+        this.eventMap = eventMap;
+    }
+
+}
diff --git a/logging-modules/log4j2/src/test/java/com/baeldung/logging/log4j2/appender/MapAppenderIntegrationTest.java b/logging-modules/log4j2/src/test/java/com/baeldung/logging/log4j2/appender/MapAppenderIntegrationTest.java
new file mode 100644
index 0000000000..020aaafc74
--- /dev/null
+++ b/logging-modules/log4j2/src/test/java/com/baeldung/logging/log4j2/appender/MapAppenderIntegrationTest.java
@@ -0,0 +1,35 @@
+package com.baeldung.logging.log4j2.appender;
+
+import static org.junit.Assert.assertEquals;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.core.LoggerContext;
+import org.apache.logging.log4j.core.config.Configuration;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
+
+@RunWith(JUnit4.class)
+public class MapAppenderIntegrationTest {
+
+    private Logger logger;
+
+    @Before
+    public void setup() {
+        logger = LogManager.getLogger(MapAppenderIntegrationTest.class);
+    }
+
+    @Test
+    public void whenLoggerEmitsLoggingEvent_thenAppenderReceivesEvent() throws Exception {
+        logger.info("Test from {}", this.getClass()
+            .getSimpleName());
+        LoggerContext context = LoggerContext.getContext(false);
+        Configuration config = context.getConfiguration();
+        MapAppender appender = config.getAppender("MapAppender");
+        assertEquals(appender.getEventMap()
+            .size(), 1);
+    }
+
+}
diff --git a/logging-modules/log4j2/src/test/resources/log4j2.xml b/logging-modules/log4j2/src/test/resources/log4j2.xml
index 83b664a507..d0fd0d088f 100644
--- a/logging-modules/log4j2/src/test/resources/log4j2.xml
+++ b/logging-modules/log4j2/src/test/resources/log4j2.xml
@@ -1,87 +1,93 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <Configuration xmlns:xi="http://www.w3.org/2001/XInclude"
-    status="WARN">
-    <Appenders>
-        <xi:include
-            href="log4j2-includes/console-appender_pattern-layout_colored.xml" />
-        <Console name="ConsoleAppender" target="SYSTEM_OUT">
-            <PatternLayout
-                pattern="%d [%t] %-5level %logger{36} - %msg%n%throwable" />
-        </Console>
-        <Console name="ConsoleRedAppender" target="SYSTEM_OUT">
-            <PatternLayout pattern="%style{%message}{red}%n" />
-            <MarkerFilter marker="CONN_TRACE" />
-        </Console>
-        <Console name="ConsoleGreenAppender" target="SYSTEM_OUT">
-            <PatternLayout
-                pattern="%style{userId=%X{userId}:}{white} %style{%message}{green}%n" />
-        </Console>
-        <Console name="ConsoleJSONAppender" target="SYSTEM_OUT">
-            <JsonLayout complete="false" compact="false">
-                <KeyValuePair key="myCustomField" value="myCustomValue" />
-            </JsonLayout>
-        </Console>
-        <File name="JSONLogfileAppender" fileName="${sys:logging.folder.path}">
-            <JSONLayout compact="true" eventEol="true" />
-            <BurstFilter level="INFO" rate="2" maxBurst="10" />
-        </File>
-        <Async name="AsyncAppender" bufferSize="80">
-            <AppenderRef ref="JSONLogfileAppender" />
-        </Async>
-        <!-- <Syslog name="Syslog" format="RFC5424" host="localhost" port="514" 
-            protocol="TCP" facility="local3" connectTimeoutMillis="10000" reconnectionDelayMillis="5000" 
-            mdcId="mdc" includeMDC="true" /> <Failover name="FailoverAppender" primary="Syslog"> 
-            <Failovers> <AppenderRef ref="ConsoleAppender" /> </Failovers> </Failover> -->
-        <JDBC name="JDBCAppender" tableName="logs">
-            <ConnectionFactory
-                class="com.baeldung.logging.log4j2.tests.jdbc.ConnectionFactory"
-                method="getConnection" />
-            <Column name="when" isEventTimestamp="true" />
-            <Column name="logger" pattern="%logger" />
-            <Column name="level" pattern="%level" />
-            <Column name="message" pattern="%message" />
-            <Column name="throwable" pattern="%ex{full}" />
-        </JDBC>
-        <RollingFile name="XMLRollingfileAppender" fileName="target/logfile.xml"
-            filePattern="target/logfile-%d{yyyy-MM-dd}-%i.log.gz">
-            <XMLLayout />
-            <Policies>
-                <SizeBasedTriggeringPolicy
-                    size="17 kB" />
-            </Policies>
-        </RollingFile>
-    </Appenders>
-    <Loggers>
-        <Logger name="CONSOLE_PATTERN_APPENDER_MARKER" level="TRACE"
-            additivity="false">
-            <AppenderRef ref="ConsoleRedAppender" />
-        </Logger>
-        <Logger name="CONSOLE_PATTERN_APPENDER_THREAD_CONTEXT"
-            level="INFO" additivity="false">
-            <AppenderRef ref="ConsoleGreenAppender" />
-            <ThreadContextMapFilter>
-                <KeyValuePair key="userId" value="1000" />
-            </ThreadContextMapFilter>
-        </Logger>
-        <Logger name="ASYNC_JSON_FILE_APPENDER" level="INFO"
-            additivity="false">
-            <AppenderRef ref="AsyncAppender" />
-        </Logger>
-        <!-- <Logger name="FAIL_OVER_SYSLOG_APPENDER" level="INFO" additivity="false"> 
-            <AppenderRef ref="FailoverAppender" /> </Logger> -->
-        <Logger name="JDBC_APPENDER" level="INFO" additivity="false">
-            <AppenderRef ref="JDBCAppender" />
-        </Logger>
-        <Logger name="XML_ROLLING_FILE_APPENDER" level="INFO"
-            additivity="false">
-            <AppenderRef ref="XMLRollingfileAppender" />
-        </Logger>
-        <Logger name="CONSOLE_JSON_APPENDER" level="TRACE"
-            additivity="false">
-            <AppenderRef ref="ConsoleJSONAppender" />
-        </Logger>
-        <Root level="DEBUG">
-            <AppenderRef ref="ConsoleAppender" />
-        </Root>
-    </Loggers>
+	packages="com.baeldung" status="WARN">
+	<Appenders>
+		<xi:include
+			href="log4j2-includes/console-appender_pattern-layout_colored.xml" />
+		<Console name="ConsoleAppender" target="SYSTEM_OUT">
+			<PatternLayout
+				pattern="%d [%t] %-5level %logger{36} - %msg%n%throwable" />
+		</Console>
+		<Console name="ConsoleRedAppender" target="SYSTEM_OUT">
+			<PatternLayout pattern="%style{%message}{red}%n" />
+			<MarkerFilter marker="CONN_TRACE" />
+		</Console>
+		<Console name="ConsoleGreenAppender" target="SYSTEM_OUT">
+			<PatternLayout
+				pattern="%style{userId=%X{userId}:}{white} %style{%message}{green}%n" />
+		</Console>
+		<Console name="ConsoleJSONAppender" target="SYSTEM_OUT">
+			<JsonLayout complete="false" compact="false">
+				<KeyValuePair key="myCustomField" value="myCustomValue" />
+			</JsonLayout>
+		</Console>
+		<File name="JSONLogfileAppender"
+			fileName="${sys:logging.folder.path}">
+			<JSONLayout compact="true" eventEol="true" />
+			<BurstFilter level="INFO" rate="2" maxBurst="10" />
+		</File>
+		<Async name="AsyncAppender" bufferSize="80">
+			<AppenderRef ref="JSONLogfileAppender" />
+		</Async>
+		<!-- <Syslog name="Syslog" format="RFC5424" host="localhost" port="514" 
+			protocol="TCP" facility="local3" connectTimeoutMillis="10000" reconnectionDelayMillis="5000" 
+			mdcId="mdc" includeMDC="true" /> <Failover name="FailoverAppender" primary="Syslog"> 
+			<Failovers> <AppenderRef ref="ConsoleAppender" /> </Failovers> </Failover> -->
+		<JDBC name="JDBCAppender" tableName="logs">
+			<ConnectionFactory
+				class="com.baeldung.logging.log4j2.tests.jdbc.ConnectionFactory"
+				method="getConnection" />
+			<Column name="when" isEventTimestamp="true" />
+			<Column name="logger" pattern="%logger" />
+			<Column name="level" pattern="%level" />
+			<Column name="message" pattern="%message" />
+			<Column name="throwable" pattern="%ex{full}" />
+		</JDBC>
+		<RollingFile name="XMLRollingfileAppender"
+			fileName="target/logfile.xml"
+			filePattern="target/logfile-%d{yyyy-MM-dd}-%i.log.gz">
+			<XMLLayout />
+			<Policies>
+				<SizeBasedTriggeringPolicy size="17 kB" />
+			</Policies>
+		</RollingFile>
+		<MapAppender name="MapAppender">
+			<PatternLayout
+				pattern=" Date: %d |  level:%level | class name:%logger | method name:%M() |  line number:%L |  Location: %l | message:%m%n" />
+		</MapAppender>
+	</Appenders>
+	<Loggers>
+		<Logger name="CONSOLE_PATTERN_APPENDER_MARKER" level="TRACE"
+			additivity="false">
+			<AppenderRef ref="ConsoleRedAppender" />
+		</Logger>
+		<Logger name="CONSOLE_PATTERN_APPENDER_THREAD_CONTEXT"
+			level="INFO" additivity="false">
+			<AppenderRef ref="ConsoleGreenAppender" />
+			<ThreadContextMapFilter>
+				<KeyValuePair key="userId" value="1000" />
+			</ThreadContextMapFilter>
+		</Logger>
+		<Logger name="ASYNC_JSON_FILE_APPENDER" level="INFO"
+			additivity="false">
+			<AppenderRef ref="AsyncAppender" />
+		</Logger>
+		<!-- <Logger name="FAIL_OVER_SYSLOG_APPENDER" level="INFO" additivity="false"> 
+			<AppenderRef ref="FailoverAppender" /> </Logger> -->
+		<Logger name="JDBC_APPENDER" level="INFO" additivity="false">
+			<AppenderRef ref="JDBCAppender" />
+		</Logger>
+		<Logger name="XML_ROLLING_FILE_APPENDER" level="INFO"
+			additivity="false">
+			<AppenderRef ref="XMLRollingfileAppender" />
+		</Logger>
+		<Logger name="CONSOLE_JSON_APPENDER" level="TRACE"
+			additivity="false">
+			<AppenderRef ref="ConsoleJSONAppender" />
+		</Logger>
+		<Root level="DEBUG">
+			<AppenderRef ref="ConsoleAppender" />
+			<AppenderRef ref="MapAppender" />
+		</Root>
+	</Loggers>
 </Configuration>
\ No newline at end of file

From 380dce8e6e629c7546222cd07ede44099c58608e Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.102>
Date: Wed, 25 Jul 2018 00:21:47 +0530
Subject: [PATCH 2/8] Changes as per suggestion to BAEL-1960

---
 .../logging/log4j2/appender/MapAppender.java  | 26 ++++++++-----------
 .../log4j2/src/test/resources/log4j2.xml      |  5 +---
 2 files changed, 12 insertions(+), 19 deletions(-)

diff --git a/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
index 160ba58395..e9c025f480 100644
--- a/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
+++ b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
@@ -3,46 +3,42 @@
  */
 package com.baeldung.logging.log4j2.appender;
 
-import java.io.Serializable;
 import java.time.Instant;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
+import org.apache.logging.log4j.Level;
 import org.apache.logging.log4j.core.Appender;
 import org.apache.logging.log4j.core.Core;
 import org.apache.logging.log4j.core.Filter;
-import org.apache.logging.log4j.core.Layout;
 import org.apache.logging.log4j.core.LogEvent;
 import org.apache.logging.log4j.core.appender.AbstractAppender;
 import org.apache.logging.log4j.core.config.plugins.Plugin;
 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.layout.PatternLayout;
 
-@Plugin(name = "MapAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = true)
+@Plugin(name = "MapAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = false)
 public class MapAppender extends AbstractAppender {
 
     private ConcurrentMap<String, LogEvent> eventMap = new ConcurrentHashMap<>();
 
-    protected MapAppender(String name, Filter filter, Layout<? extends Serializable> layout) {
-        super(name, filter, layout);
+    protected MapAppender(String name, Filter filter) {
+        super(name, filter, null);
     }
 
     @PluginFactory
-    public static MapAppender createAppender(@PluginAttribute("name") String name, @PluginElement("Layout") Layout<? extends Serializable> layout, @PluginElement("Filter") final Filter filter) {
-        if (name == null) {
-            LOGGER.error("No name provided for MapAppender");
-            return null;
-        }
-        if (layout == null) {
-            layout = PatternLayout.createDefaultLayout();
-        }
-        return new MapAppender(name, filter, layout);
+    public static MapAppender createAppender(@PluginAttribute("name") String name, @PluginElement("Filter") final Filter filter) {
+        return new MapAppender(name, filter);
     }
 
     @Override
     public void append(LogEvent event) {
+        if (event.getLevel()
+            .isLessSpecificThan(Level.WARN)) {
+            error("Unable to log less than WARN level.");
+            return;
+        }
         eventMap.put(Instant.now()
             .toString(), event);
     }
diff --git a/logging-modules/log4j2/src/test/resources/log4j2.xml b/logging-modules/log4j2/src/test/resources/log4j2.xml
index d0fd0d088f..eefa00e1ba 100644
--- a/logging-modules/log4j2/src/test/resources/log4j2.xml
+++ b/logging-modules/log4j2/src/test/resources/log4j2.xml
@@ -51,10 +51,7 @@
 				<SizeBasedTriggeringPolicy size="17 kB" />
 			</Policies>
 		</RollingFile>
-		<MapAppender name="MapAppender">
-			<PatternLayout
-				pattern=" Date: %d |  level:%level | class name:%logger | method name:%M() |  line number:%L |  Location: %l | message:%m%n" />
-		</MapAppender>
+		<MapAppender name="MapAppender"/>
 	</Appenders>
 	<Loggers>
 		<Logger name="CONSOLE_PATTERN_APPENDER_MARKER" level="TRACE"

From c45c6d9ff1bcdd3a9afc211580c030c489cb3325 Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.100>
Date: Wed, 25 Jul 2018 23:24:03 +0530
Subject: [PATCH 3/8] Changes as [er review for BAEL-1960

---
 logging-modules/log4j2/pom.xml                | 216 +++++++++---------
 .../logging/log4j2/appender/MapAppender.java  |   2 +-
 2 files changed, 108 insertions(+), 110 deletions(-)

diff --git a/logging-modules/log4j2/pom.xml b/logging-modules/log4j2/pom.xml
index b577931f0f..9d8a523462 100644
--- a/logging-modules/log4j2/pom.xml
+++ b/logging-modules/log4j2/pom.xml
@@ -1,25 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-	<modelVersion>4.0.0</modelVersion>
-	<artifactId>log4j2</artifactId>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>log4j2</artifactId>
 
-	<parent>
-		<groupId>com.baeldung</groupId>
-		<artifactId>parent-modules</artifactId>
-		<version>1.0.0-SNAPSHOT</version>
-		<relativePath>../../</relativePath>
-	</parent>
-
-	<dependencies>
-		<!-- This is the needed core component. -->
-		<dependency>
-			<groupId>org.apache.logging.log4j</groupId>
-			<artifactId>log4j-core</artifactId>
-			<version>${log4j-core.version}</version>
-		</dependency>
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
+    </parent>
 
+    <dependencies>
+        <!-- This is the needed core component. -->
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j-core.version}</version>
+        </dependency>
+        
 		<!-- This is the needed API component. -->
 		<dependency>
 			<groupId>org.apache.logging.log4j</groupId>
@@ -27,100 +26,99 @@
 			<version>${log4j-core.version}</version>
 		</dependency>
 
+        <!-- This is used by JSONLayout. -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
 
-		<!-- This is used by JSONLayout. -->
-		<dependency>
-			<groupId>com.fasterxml.jackson.core</groupId>
-			<artifactId>jackson-databind</artifactId>
-			<version>${jackson.version}</version>
-		</dependency>
+        <!-- This is used by XMLLayout. -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
 
-		<!-- This is used by XMLLayout. -->
-		<dependency>
-			<groupId>com.fasterxml.jackson.dataformat</groupId>
-			<artifactId>jackson-dataformat-xml</artifactId>
-			<version>${jackson.version}</version>
-		</dependency>
+        <!-- This is used by JDBC Appender. -->
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <version>${h2.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-dbcp2</artifactId>
+            <version>${commons-dbcp2.version}</version>
+        </dependency>
 
-		<!-- This is used by JDBC Appender. -->
-		<dependency>
-			<groupId>com.h2database</groupId>
-			<artifactId>h2</artifactId>
-			<version>${h2.version}</version>
-		</dependency>
-		<dependency>
-			<groupId>org.apache.commons</groupId>
-			<artifactId>commons-dbcp2</artifactId>
-			<version>${commons-dbcp2.version}</version>
-		</dependency>
+        <!-- This is used for testing only. -->
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j-core.version}</version>
+            <type>test-jar</type>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 
-		<!-- This is used for testing only. -->
-		<dependency>
-			<groupId>org.apache.logging.log4j</groupId>
-			<artifactId>log4j-core</artifactId>
-			<version>${log4j-core.version}</version>
-			<type>test-jar</type>
-			<scope>test</scope>
-		</dependency>
-	</dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <proc>none</proc>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 
-	<build>
-		<plugins>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-compiler-plugin</artifactId>
-				<version>${maven-compiler-plugin.version}</version>
-				<configuration>
-					<proc>none</proc>
-				</configuration>
-			</plugin>
-		</plugins>
-	</build>
+    <profiles>
+        <profile>
+            <id>integration</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <executions>
+                            <execution>
+                                <phase>integration-test</phase>
+                                <goals>
+                                    <goal>test</goal>
+                                </goals>
+                                <configuration>
+                                    <excludes>
+                                        <exclude>**/*ManualTest.java</exclude>
+                                        <exclude>**/*LiveTest.java</exclude>
+                                    </excludes>
+                                    <includes>
+                                        <include>**/*IntegrationTest.java</include>
+                                        <include>**/*IntTest.java</include>
+                                    </includes>
+                                </configuration>
+                            </execution>
+                        </executions>
+                        <configuration>
+                            <systemPropertyVariables>
+                                <test.mime>json</test.mime>
+                                <logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
+                            </systemPropertyVariables>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
 
-	<profiles>
-		<profile>
-			<id>integration</id>
-			<build>
-				<plugins>
-					<plugin>
-						<groupId>org.apache.maven.plugins</groupId>
-						<artifactId>maven-surefire-plugin</artifactId>
-						<executions>
-							<execution>
-								<phase>integration-test</phase>
-								<goals>
-									<goal>test</goal>
-								</goals>
-								<configuration>
-									<excludes>
-										<exclude>**/*ManualTest.java</exclude>
-										<exclude>**/*LiveTest.java</exclude>
-									</excludes>
-									<includes>
-										<include>**/*IntegrationTest.java</include>
-										<include>**/*IntTest.java</include>
-									</includes>
-								</configuration>
-							</execution>
-						</executions>
-						<configuration>
-							<systemPropertyVariables>
-								<test.mime>json</test.mime>
-								<logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
-							</systemPropertyVariables>
-						</configuration>
-					</plugin>
-				</plugins>
-			</build>
-		</profile>
-	</profiles>
+    <properties>
+        <jackson.version>2.9.5</jackson.version>
+        <h2.version>1.4.193</h2.version>
+        <commons-dbcp2.version>2.1.1</commons-dbcp2.version>
+        <log4j-core.version>2.11.0</log4j-core.version>
+        <maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
+    </properties>
 
-	<properties>
-		<jackson.version>2.9.5</jackson.version>
-		<h2.version>1.4.193</h2.version>
-		<commons-dbcp2.version>2.1.1</commons-dbcp2.version>
-		<log4j-core.version>2.11.0</log4j-core.version>
-		<maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
-	</properties>
-
-</project>
+</project>
\ No newline at end of file
diff --git a/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
index e9c025f480..2015b6d573 100644
--- a/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
+++ b/logging-modules/log4j2/src/main/java/com/baeldung/logging/log4j2/appender/MapAppender.java
@@ -18,7 +18,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;
 
-@Plugin(name = "MapAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE, printObject = false)
+@Plugin(name = "MapAppender", category = Core.CATEGORY_NAME, elementType = Appender.ELEMENT_TYPE)
 public class MapAppender extends AbstractAppender {
 
     private ConcurrentMap<String, LogEvent> eventMap = new ConcurrentHashMap<>();

From 73bd03a331ac2e6f2e6b1e7e9263fe81b275ca6a Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.100>
Date: Wed, 25 Jul 2018 23:27:14 +0530
Subject: [PATCH 4/8] Changes for formatting as per suggestion.

---
 logging-modules/log4j2/pom.xml | 213 +++++++++++++++++----------------
 1 file changed, 107 insertions(+), 106 deletions(-)

diff --git a/logging-modules/log4j2/pom.xml b/logging-modules/log4j2/pom.xml
index 9d8a523462..f6b3fea227 100644
--- a/logging-modules/log4j2/pom.xml
+++ b/logging-modules/log4j2/pom.xml
@@ -1,24 +1,25 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <artifactId>log4j2</artifactId>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<artifactId>log4j2</artifactId>
 
-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-modules</artifactId>
-        <version>1.0.0-SNAPSHOT</version>
-        <relativePath>../../</relativePath>
-    </parent>
+	<parent>
+		<groupId>com.baeldung</groupId>
+		<artifactId>parent-modules</artifactId>
+		<version>1.0.0-SNAPSHOT</version>
+		<relativePath>../../</relativePath>
+	</parent>
+
+	<dependencies>
+		<!-- This is the needed core component. -->
+		<dependency>
+			<groupId>org.apache.logging.log4j</groupId>
+			<artifactId>log4j-core</artifactId>
+			<version>${log4j-core.version}</version>
+		</dependency>
 
-    <dependencies>
-        <!-- This is the needed core component. -->
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j-core.version}</version>
-        </dependency>
-        
 		<!-- This is the needed API component. -->
 		<dependency>
 			<groupId>org.apache.logging.log4j</groupId>
@@ -26,99 +27,99 @@
 			<version>${log4j-core.version}</version>
 		</dependency>
 
-        <!-- This is used by JSONLayout. -->
-        <dependency>
-            <groupId>com.fasterxml.jackson.core</groupId>
-            <artifactId>jackson-databind</artifactId>
-            <version>${jackson.version}</version>
-        </dependency>
+		<!-- This is used by JSONLayout. -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>${jackson.version}</version>
+		</dependency>
 
-        <!-- This is used by XMLLayout. -->
-        <dependency>
-            <groupId>com.fasterxml.jackson.dataformat</groupId>
-            <artifactId>jackson-dataformat-xml</artifactId>
-            <version>${jackson.version}</version>
-        </dependency>
+		<!-- This is used by XMLLayout. -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.dataformat</groupId>
+			<artifactId>jackson-dataformat-xml</artifactId>
+			<version>${jackson.version}</version>
+		</dependency>
 
-        <!-- This is used by JDBC Appender. -->
-        <dependency>
-            <groupId>com.h2database</groupId>
-            <artifactId>h2</artifactId>
-            <version>${h2.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.commons</groupId>
-            <artifactId>commons-dbcp2</artifactId>
-            <version>${commons-dbcp2.version}</version>
-        </dependency>
+		<!-- This is used by JDBC Appender. -->
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<version>${h2.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-dbcp2</artifactId>
+			<version>${commons-dbcp2.version}</version>
+		</dependency>
 
-        <!-- This is used for testing only. -->
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>${log4j-core.version}</version>
-            <type>test-jar</type>
-            <scope>test</scope>
-        </dependency>
-    </dependencies>
+		<!-- This is used for testing only. -->
+		<dependency>
+			<groupId>org.apache.logging.log4j</groupId>
+			<artifactId>log4j-core</artifactId>
+			<version>${log4j-core.version}</version>
+			<type>test-jar</type>
+			<scope>test</scope>
+		</dependency>
+	</dependencies>
 
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>${maven-compiler-plugin.version}</version>
-                <configuration>
-                    <proc>none</proc>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>${maven-compiler-plugin.version}</version>
+				<configuration>
+					<proc>none</proc>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
 
-    <profiles>
-        <profile>
-            <id>integration</id>
-            <build>
-                <plugins>
-                    <plugin>
-                        <groupId>org.apache.maven.plugins</groupId>
-                        <artifactId>maven-surefire-plugin</artifactId>
-                        <executions>
-                            <execution>
-                                <phase>integration-test</phase>
-                                <goals>
-                                    <goal>test</goal>
-                                </goals>
-                                <configuration>
-                                    <excludes>
-                                        <exclude>**/*ManualTest.java</exclude>
-                                        <exclude>**/*LiveTest.java</exclude>
-                                    </excludes>
-                                    <includes>
-                                        <include>**/*IntegrationTest.java</include>
-                                        <include>**/*IntTest.java</include>
-                                    </includes>
-                                </configuration>
-                            </execution>
-                        </executions>
-                        <configuration>
-                            <systemPropertyVariables>
-                                <test.mime>json</test.mime>
-                                <logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
-                            </systemPropertyVariables>
-                        </configuration>
-                    </plugin>
-                </plugins>
-            </build>
-        </profile>
-    </profiles>
+	<profiles>
+		<profile>
+			<id>integration</id>
+			<build>
+				<plugins>
+					<plugin>
+						<groupId>org.apache.maven.plugins</groupId>
+						<artifactId>maven-surefire-plugin</artifactId>
+						<executions>
+							<execution>
+								<phase>integration-test</phase>
+								<goals>
+									<goal>test</goal>
+								</goals>
+								<configuration>
+									<excludes>
+										<exclude>**/*ManualTest.java</exclude>
+										<exclude>**/*LiveTest.java</exclude>
+									</excludes>
+									<includes>
+										<include>**/*IntegrationTest.java</include>
+										<include>**/*IntTest.java</include>
+									</includes>
+								</configuration>
+							</execution>
+						</executions>
+						<configuration>
+							<systemPropertyVariables>
+								<test.mime>json</test.mime>
+								<logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
+							</systemPropertyVariables>
+						</configuration>
+					</plugin>
+				</plugins>
+			</build>
+		</profile>
+	</profiles>
 
-    <properties>
-        <jackson.version>2.9.5</jackson.version>
-        <h2.version>1.4.193</h2.version>
-        <commons-dbcp2.version>2.1.1</commons-dbcp2.version>
-        <log4j-core.version>2.11.0</log4j-core.version>
-        <maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
-    </properties>
+	<properties>
+		<jackson.version>2.9.5</jackson.version>
+		<h2.version>1.4.193</h2.version>
+		<commons-dbcp2.version>2.1.1</commons-dbcp2.version>
+		<log4j-core.version>2.11.0</log4j-core.version>
+		<maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
+	</properties>
 
 </project>
\ No newline at end of file

From 74787e9026ef52645fcc3178869624b91bfee6c6 Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.100>
Date: Wed, 25 Jul 2018 23:30:08 +0530
Subject: [PATCH 5/8] BAEL-1960. Copied pom.xml from master and pasted my
 changes against it.

---
 logging-modules/log4j2/pom.xml | 213 ++++++++++++++++-----------------
 1 file changed, 106 insertions(+), 107 deletions(-)

diff --git a/logging-modules/log4j2/pom.xml b/logging-modules/log4j2/pom.xml
index f6b3fea227..9d8a523462 100644
--- a/logging-modules/log4j2/pom.xml
+++ b/logging-modules/log4j2/pom.xml
@@ -1,25 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-	<modelVersion>4.0.0</modelVersion>
-	<artifactId>log4j2</artifactId>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>log4j2</artifactId>
 
-	<parent>
-		<groupId>com.baeldung</groupId>
-		<artifactId>parent-modules</artifactId>
-		<version>1.0.0-SNAPSHOT</version>
-		<relativePath>../../</relativePath>
-	</parent>
-
-	<dependencies>
-		<!-- This is the needed core component. -->
-		<dependency>
-			<groupId>org.apache.logging.log4j</groupId>
-			<artifactId>log4j-core</artifactId>
-			<version>${log4j-core.version}</version>
-		</dependency>
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
+    </parent>
 
+    <dependencies>
+        <!-- This is the needed core component. -->
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j-core.version}</version>
+        </dependency>
+        
 		<!-- This is the needed API component. -->
 		<dependency>
 			<groupId>org.apache.logging.log4j</groupId>
@@ -27,99 +26,99 @@
 			<version>${log4j-core.version}</version>
 		</dependency>
 
-		<!-- This is used by JSONLayout. -->
-		<dependency>
-			<groupId>com.fasterxml.jackson.core</groupId>
-			<artifactId>jackson-databind</artifactId>
-			<version>${jackson.version}</version>
-		</dependency>
+        <!-- This is used by JSONLayout. -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
 
-		<!-- This is used by XMLLayout. -->
-		<dependency>
-			<groupId>com.fasterxml.jackson.dataformat</groupId>
-			<artifactId>jackson-dataformat-xml</artifactId>
-			<version>${jackson.version}</version>
-		</dependency>
+        <!-- This is used by XMLLayout. -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-xml</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
 
-		<!-- This is used by JDBC Appender. -->
-		<dependency>
-			<groupId>com.h2database</groupId>
-			<artifactId>h2</artifactId>
-			<version>${h2.version}</version>
-		</dependency>
-		<dependency>
-			<groupId>org.apache.commons</groupId>
-			<artifactId>commons-dbcp2</artifactId>
-			<version>${commons-dbcp2.version}</version>
-		</dependency>
+        <!-- This is used by JDBC Appender. -->
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <version>${h2.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-dbcp2</artifactId>
+            <version>${commons-dbcp2.version}</version>
+        </dependency>
 
-		<!-- This is used for testing only. -->
-		<dependency>
-			<groupId>org.apache.logging.log4j</groupId>
-			<artifactId>log4j-core</artifactId>
-			<version>${log4j-core.version}</version>
-			<type>test-jar</type>
-			<scope>test</scope>
-		</dependency>
-	</dependencies>
+        <!-- This is used for testing only. -->
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j-core.version}</version>
+            <type>test-jar</type>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 
-	<build>
-		<plugins>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-compiler-plugin</artifactId>
-				<version>${maven-compiler-plugin.version}</version>
-				<configuration>
-					<proc>none</proc>
-				</configuration>
-			</plugin>
-		</plugins>
-	</build>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <proc>none</proc>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 
-	<profiles>
-		<profile>
-			<id>integration</id>
-			<build>
-				<plugins>
-					<plugin>
-						<groupId>org.apache.maven.plugins</groupId>
-						<artifactId>maven-surefire-plugin</artifactId>
-						<executions>
-							<execution>
-								<phase>integration-test</phase>
-								<goals>
-									<goal>test</goal>
-								</goals>
-								<configuration>
-									<excludes>
-										<exclude>**/*ManualTest.java</exclude>
-										<exclude>**/*LiveTest.java</exclude>
-									</excludes>
-									<includes>
-										<include>**/*IntegrationTest.java</include>
-										<include>**/*IntTest.java</include>
-									</includes>
-								</configuration>
-							</execution>
-						</executions>
-						<configuration>
-							<systemPropertyVariables>
-								<test.mime>json</test.mime>
-								<logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
-							</systemPropertyVariables>
-						</configuration>
-					</plugin>
-				</plugins>
-			</build>
-		</profile>
-	</profiles>
+    <profiles>
+        <profile>
+            <id>integration</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <executions>
+                            <execution>
+                                <phase>integration-test</phase>
+                                <goals>
+                                    <goal>test</goal>
+                                </goals>
+                                <configuration>
+                                    <excludes>
+                                        <exclude>**/*ManualTest.java</exclude>
+                                        <exclude>**/*LiveTest.java</exclude>
+                                    </excludes>
+                                    <includes>
+                                        <include>**/*IntegrationTest.java</include>
+                                        <include>**/*IntTest.java</include>
+                                    </includes>
+                                </configuration>
+                            </execution>
+                        </executions>
+                        <configuration>
+                            <systemPropertyVariables>
+                                <test.mime>json</test.mime>
+                                <logging.folder.path>${java.io.tmpdir}/${maven.build.timestamp}/logfile.json</logging.folder.path>
+                            </systemPropertyVariables>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
 
-	<properties>
-		<jackson.version>2.9.5</jackson.version>
-		<h2.version>1.4.193</h2.version>
-		<commons-dbcp2.version>2.1.1</commons-dbcp2.version>
-		<log4j-core.version>2.11.0</log4j-core.version>
-		<maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
-	</properties>
+    <properties>
+        <jackson.version>2.9.5</jackson.version>
+        <h2.version>1.4.193</h2.version>
+        <commons-dbcp2.version>2.1.1</commons-dbcp2.version>
+        <log4j-core.version>2.11.0</log4j-core.version>
+        <maven.build.timestamp.format>yyyyMMddHHmmss</maven.build.timestamp.format>
+    </properties>
 
 </project>
\ No newline at end of file

From cd4dbef187d546940ed816c685d84d54b18f6ccf Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.87>
Date: Thu, 26 Jul 2018 12:49:30 +0530
Subject: [PATCH 6/8] Chnages for spaces instead of tabs.

---
 logging-modules/log4j2/pom.xml | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/logging-modules/log4j2/pom.xml b/logging-modules/log4j2/pom.xml
index 9d8a523462..65da318636 100644
--- a/logging-modules/log4j2/pom.xml
+++ b/logging-modules/log4j2/pom.xml
@@ -19,12 +19,12 @@
             <version>${log4j-core.version}</version>
         </dependency>
         
-		<!-- This is the needed API component. -->
-		<dependency>
-			<groupId>org.apache.logging.log4j</groupId>
-			<artifactId>log4j-api</artifactId>
-			<version>${log4j-core.version}</version>
-		</dependency>
+        <!-- This is the needed API component. -->
+        <dependency>
+          <groupId>org.apache.logging.log4j</groupId>
+          <artifactId>log4j-api</artifactId>
+          <version>${log4j-core.version}</version>
+        </dependency>
 
         <!-- This is used by JSONLayout. -->
         <dependency>

From 2f0b1b46c9feb66ecc7ec622f03626bf824352a3 Mon Sep 17 00:00:00 2001
From: root <root@192.168.0.87>
Date: Thu, 26 Jul 2018 12:54:28 +0530
Subject: [PATCH 7/8] Changes for spaces instead of tabs.

---
 .../log4j2/src/test/resources/log4j2.xml      | 175 +++++++++---------
 1 file changed, 87 insertions(+), 88 deletions(-)

diff --git a/logging-modules/log4j2/src/test/resources/log4j2.xml b/logging-modules/log4j2/src/test/resources/log4j2.xml
index eefa00e1ba..246ffb0707 100644
--- a/logging-modules/log4j2/src/test/resources/log4j2.xml
+++ b/logging-modules/log4j2/src/test/resources/log4j2.xml
@@ -1,90 +1,89 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<Configuration xmlns:xi="http://www.w3.org/2001/XInclude"
-	packages="com.baeldung" status="WARN">
-	<Appenders>
-		<xi:include
-			href="log4j2-includes/console-appender_pattern-layout_colored.xml" />
-		<Console name="ConsoleAppender" target="SYSTEM_OUT">
-			<PatternLayout
-				pattern="%d [%t] %-5level %logger{36} - %msg%n%throwable" />
-		</Console>
-		<Console name="ConsoleRedAppender" target="SYSTEM_OUT">
-			<PatternLayout pattern="%style{%message}{red}%n" />
-			<MarkerFilter marker="CONN_TRACE" />
-		</Console>
-		<Console name="ConsoleGreenAppender" target="SYSTEM_OUT">
-			<PatternLayout
-				pattern="%style{userId=%X{userId}:}{white} %style{%message}{green}%n" />
-		</Console>
-		<Console name="ConsoleJSONAppender" target="SYSTEM_OUT">
-			<JsonLayout complete="false" compact="false">
-				<KeyValuePair key="myCustomField" value="myCustomValue" />
-			</JsonLayout>
-		</Console>
-		<File name="JSONLogfileAppender"
-			fileName="${sys:logging.folder.path}">
-			<JSONLayout compact="true" eventEol="true" />
-			<BurstFilter level="INFO" rate="2" maxBurst="10" />
-		</File>
-		<Async name="AsyncAppender" bufferSize="80">
-			<AppenderRef ref="JSONLogfileAppender" />
-		</Async>
-		<!-- <Syslog name="Syslog" format="RFC5424" host="localhost" port="514" 
-			protocol="TCP" facility="local3" connectTimeoutMillis="10000" reconnectionDelayMillis="5000" 
-			mdcId="mdc" includeMDC="true" /> <Failover name="FailoverAppender" primary="Syslog"> 
-			<Failovers> <AppenderRef ref="ConsoleAppender" /> </Failovers> </Failover> -->
-		<JDBC name="JDBCAppender" tableName="logs">
-			<ConnectionFactory
-				class="com.baeldung.logging.log4j2.tests.jdbc.ConnectionFactory"
-				method="getConnection" />
-			<Column name="when" isEventTimestamp="true" />
-			<Column name="logger" pattern="%logger" />
-			<Column name="level" pattern="%level" />
-			<Column name="message" pattern="%message" />
-			<Column name="throwable" pattern="%ex{full}" />
-		</JDBC>
-		<RollingFile name="XMLRollingfileAppender"
-			fileName="target/logfile.xml"
-			filePattern="target/logfile-%d{yyyy-MM-dd}-%i.log.gz">
-			<XMLLayout />
-			<Policies>
-				<SizeBasedTriggeringPolicy size="17 kB" />
-			</Policies>
-		</RollingFile>
-		<MapAppender name="MapAppender"/>
-	</Appenders>
-	<Loggers>
-		<Logger name="CONSOLE_PATTERN_APPENDER_MARKER" level="TRACE"
-			additivity="false">
-			<AppenderRef ref="ConsoleRedAppender" />
-		</Logger>
-		<Logger name="CONSOLE_PATTERN_APPENDER_THREAD_CONTEXT"
-			level="INFO" additivity="false">
-			<AppenderRef ref="ConsoleGreenAppender" />
-			<ThreadContextMapFilter>
-				<KeyValuePair key="userId" value="1000" />
-			</ThreadContextMapFilter>
-		</Logger>
-		<Logger name="ASYNC_JSON_FILE_APPENDER" level="INFO"
-			additivity="false">
-			<AppenderRef ref="AsyncAppender" />
-		</Logger>
-		<!-- <Logger name="FAIL_OVER_SYSLOG_APPENDER" level="INFO" additivity="false"> 
-			<AppenderRef ref="FailoverAppender" /> </Logger> -->
-		<Logger name="JDBC_APPENDER" level="INFO" additivity="false">
-			<AppenderRef ref="JDBCAppender" />
-		</Logger>
-		<Logger name="XML_ROLLING_FILE_APPENDER" level="INFO"
-			additivity="false">
-			<AppenderRef ref="XMLRollingfileAppender" />
-		</Logger>
-		<Logger name="CONSOLE_JSON_APPENDER" level="TRACE"
-			additivity="false">
-			<AppenderRef ref="ConsoleJSONAppender" />
-		</Logger>
-		<Root level="DEBUG">
-			<AppenderRef ref="ConsoleAppender" />
-			<AppenderRef ref="MapAppender" />
-		</Root>
-	</Loggers>
+<Configuration xmlns:xi="http://www.w3.org/2001/XInclude" 
+    packages="com.baeldung" status="WARN">
+    <Appenders>
+        <xi:include
+            href="log4j2-includes/console-appender_pattern-layout_colored.xml" />
+        <Console name="ConsoleAppender" target="SYSTEM_OUT">
+            <PatternLayout
+                pattern="%d [%t] %-5level %logger{36} - %msg%n%throwable" />
+        </Console>
+        <Console name="ConsoleRedAppender" target="SYSTEM_OUT">
+            <PatternLayout pattern="%style{%message}{red}%n" />
+            <MarkerFilter marker="CONN_TRACE" />
+        </Console>
+        <Console name="ConsoleGreenAppender" target="SYSTEM_OUT">
+            <PatternLayout
+                pattern="%style{userId=%X{userId}:}{white} %style{%message}{green}%n" />
+        </Console>
+        <Console name="ConsoleJSONAppender" target="SYSTEM_OUT">
+            <JsonLayout complete="false" compact="false">
+                <KeyValuePair key="myCustomField" value="myCustomValue" />
+            </JsonLayout>
+        </Console>
+        <File name="JSONLogfileAppender" fileName="${sys:logging.folder.path}">
+            <JSONLayout compact="true" eventEol="true" />
+            <BurstFilter level="INFO" rate="2" maxBurst="10" />
+        </File>
+        <Async name="AsyncAppender" bufferSize="80">
+            <AppenderRef ref="JSONLogfileAppender" />
+        </Async>
+        <!-- <Syslog name="Syslog" format="RFC5424" host="localhost" port="514" 
+            protocol="TCP" facility="local3" connectTimeoutMillis="10000" reconnectionDelayMillis="5000" 
+            mdcId="mdc" includeMDC="true" /> <Failover name="FailoverAppender" primary="Syslog"> 
+            <Failovers> <AppenderRef ref="ConsoleAppender" /> </Failovers> </Failover> -->
+        <JDBC name="JDBCAppender" tableName="logs">
+            <ConnectionFactory
+                class="com.baeldung.logging.log4j2.tests.jdbc.ConnectionFactory"
+                method="getConnection" />
+            <Column name="when" isEventTimestamp="true" />
+            <Column name="logger" pattern="%logger" />
+            <Column name="level" pattern="%level" />
+            <Column name="message" pattern="%message" />
+            <Column name="throwable" pattern="%ex{full}" />
+        </JDBC>
+        <RollingFile name="XMLRollingfileAppender" fileName="target/logfile.xml"
+            filePattern="target/logfile-%d{yyyy-MM-dd}-%i.log.gz">
+            <XMLLayout />
+            <Policies>
+                <SizeBasedTriggeringPolicy
+                    size="17 kB" />
+            </Policies>
+        </RollingFile>
+        <MapAppender name="MapAppender"/>
+    </Appenders>
+    <Loggers>
+        <Logger name="CONSOLE_PATTERN_APPENDER_MARKER" level="TRACE"
+            additivity="false">
+            <AppenderRef ref="ConsoleRedAppender" />
+        </Logger>
+        <Logger name="CONSOLE_PATTERN_APPENDER_THREAD_CONTEXT"
+            level="INFO" additivity="false">
+            <AppenderRef ref="ConsoleGreenAppender" />
+            <ThreadContextMapFilter>
+                <KeyValuePair key="userId" value="1000" />
+            </ThreadContextMapFilter>
+        </Logger>
+        <Logger name="ASYNC_JSON_FILE_APPENDER" level="INFO"
+            additivity="false">
+            <AppenderRef ref="AsyncAppender" />
+        </Logger>
+        <!-- <Logger name="FAIL_OVER_SYSLOG_APPENDER" level="INFO" additivity="false"> 
+            <AppenderRef ref="FailoverAppender" /> </Logger> -->
+        <Logger name="JDBC_APPENDER" level="INFO" additivity="false">
+            <AppenderRef ref="JDBCAppender" />
+        </Logger>
+        <Logger name="XML_ROLLING_FILE_APPENDER" level="INFO"
+            additivity="false">
+            <AppenderRef ref="XMLRollingfileAppender" />
+        </Logger>
+        <Logger name="CONSOLE_JSON_APPENDER" level="TRACE"
+            additivity="false">
+            <AppenderRef ref="ConsoleJSONAppender" />
+        </Logger>
+        <Root level="DEBUG">
+            <AppenderRef ref="ConsoleAppender" />
+            <AppenderRef ref="MapAppender" />
+        </Root>
+    </Loggers>
 </Configuration>
\ No newline at end of file

From 0be91964dfda73817a65d747e1d885cc838d4be1 Mon Sep 17 00:00:00 2001
From: Shreyash <shreyash.thakare@gmail.com>
Date: Tue, 7 Aug 2018 13:14:21 +0530
Subject: [PATCH 8/8] BAEL-1164 hzaelcast Jet.

---
 hazelcast/pom.xml                             | 20 +++-----
 .../baeldung/hazelcast/jet/WordCounter.java   | 51 +++++++++++++++++++
 .../hazelcast/jet/WordCounterUnitTest.java    | 21 ++++++++
 3 files changed, 80 insertions(+), 12 deletions(-)
 create mode 100644 hazelcast/src/main/java/com/baeldung/hazelcast/jet/WordCounter.java
 create mode 100644 hazelcast/src/test/java/com/baeldung/hazelcast/jet/WordCounterUnitTest.java

diff --git a/hazelcast/pom.xml b/hazelcast/pom.xml
index cc366cd0a6..705792ad05 100644
--- a/hazelcast/pom.xml
+++ b/hazelcast/pom.xml
@@ -13,16 +13,12 @@
     </parent>
 
     <dependencies>
-        <dependency>
-            <groupId>com.hazelcast</groupId>
-            <artifactId>hazelcast</artifactId>
-            <version>${hazelcast.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.hazelcast</groupId>
-            <artifactId>hazelcast-client</artifactId>
-            <version>${hazelcast.version}</version>
-        </dependency>
+        <!-- Hazelcast Jet -->
+		<dependency>
+          <groupId>com.hazelcast.jet</groupId>
+          <artifactId>hazelcast-jet</artifactId>
+          <version>${hazelcast.jet.version}</version>
+		</dependency>
     </dependencies>
 
     <build>
@@ -36,8 +32,8 @@
     </build>
 
     <properties>
-        <!-- hazelcast -->
-        <hazelcast.version>3.8.4</hazelcast.version>
+        <!-- hazelcast jet-->
+        <hazelcast.jet.version>0.6</hazelcast.jet.version>
     </properties>
 
 </project>
\ No newline at end of file
diff --git a/hazelcast/src/main/java/com/baeldung/hazelcast/jet/WordCounter.java b/hazelcast/src/main/java/com/baeldung/hazelcast/jet/WordCounter.java
new file mode 100644
index 0000000000..971986bcae
--- /dev/null
+++ b/hazelcast/src/main/java/com/baeldung/hazelcast/jet/WordCounter.java
@@ -0,0 +1,51 @@
+package com.baeldung.hazelcast.jet;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.hazelcast.jet.Traversers.traverseArray;
+import static com.hazelcast.jet.aggregate.AggregateOperations.counting;
+import static com.hazelcast.jet.function.DistributedFunctions.wholeItem;
+
+import com.hazelcast.jet.Jet;
+import com.hazelcast.jet.JetInstance;
+import com.hazelcast.jet.pipeline.Pipeline;
+import com.hazelcast.jet.pipeline.Sinks;
+import com.hazelcast.jet.pipeline.Sources;
+
+public class WordCounter {
+
+    private static final String LIST_NAME = "textList";
+
+    private static final String MAP_NAME = "countMap";
+
+    private Pipeline createPipeLine() {
+        Pipeline p = Pipeline.create();
+        p.drawFrom(Sources.<String> list(LIST_NAME))
+            .flatMap(word -> traverseArray(word.toLowerCase()
+                .split("\\W+")))
+            .filter(word -> !word.isEmpty())
+            .groupingKey(wholeItem())
+            .aggregate(counting())
+            .drainTo(Sinks.map(MAP_NAME));
+        return p;
+    }
+
+    public Long countWord(List<String> sentences, String word) {
+        long count = 0;
+        JetInstance jet = Jet.newJetInstance();
+        try {
+            List<String> textList = jet.getList(LIST_NAME);
+            textList.addAll(sentences);
+            Pipeline p = createPipeLine();
+            jet.newJob(p)
+                .join();
+            Map<String, Long> counts = jet.getMap(MAP_NAME);
+            count = counts.get(word);
+        } finally {
+            Jet.shutdownAll();
+        }
+        return count;
+    }
+
+}
diff --git a/hazelcast/src/test/java/com/baeldung/hazelcast/jet/WordCounterUnitTest.java b/hazelcast/src/test/java/com/baeldung/hazelcast/jet/WordCounterUnitTest.java
new file mode 100644
index 0000000000..95596b3860
--- /dev/null
+++ b/hazelcast/src/test/java/com/baeldung/hazelcast/jet/WordCounterUnitTest.java
@@ -0,0 +1,21 @@
+package com.baeldung.hazelcast.jet;
+
+import static org.junit.Assert.assertTrue;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Test;
+
+public class WordCounterUnitTest {
+
+    @Test
+    public void whenGivenSentencesAndWord_ThenReturnCountOfWord() {
+        List<String> sentences = new ArrayList<>();
+        sentences.add("The first second was alright, but the second second was tough.");
+        WordCounter wordCounter = new WordCounter();
+        long countSecond = wordCounter.countWord(sentences, "second");
+        assertTrue(countSecond == 3);
+    }
+
+}