### Eclipse Workspace Patch 1.0 #P log4j-flume-ng Index: src/test/java/org/apache/logging/log4j/flume/appender/FlumePersistentAppenderTest.java =================================================================== --- src/test/java/org/apache/logging/log4j/flume/appender/FlumePersistentAppenderTest.java (revision 1526621) +++ src/test/java/org/apache/logging/log4j/flume/appender/FlumePersistentAppenderTest.java (working copy) @@ -275,6 +275,19 @@ fields[i]); } } + + @Test + public void testRFC5424Layout() throws InterruptedException, IOException { + + final StructuredDataMessage msg = new StructuredDataMessage("Test", "Test Log4j", "Test"); + EventLogger.logEvent(msg); + + final Event event = primary.poll(); + Assert.assertNotNull(event); + final String body = getBody(event); + Assert.assertTrue("Structured message does not contain @EID: " + body, + body.contains("Test@18060")); + } private class WriterThread extends Thread {