@@ -0,0 +1,1184 @@
+package org.apache.flume.serialization;%0A%0Aimport org.apache.flume.interceptor.EnrichedEventBody;%0Aimport org.apache.flume.interceptor.EnrichmentInterceptor;%0Aimport org.slf4j.LoggerFactory;%0Aimport org.testng.Assert;%0Aimport org.testng.annotations.Test;%0A%0Aimport java.io.IOException;%0A%0Apublic class JSONStringSerializerTest %7B%0A%0A    private static final org.slf4j.Logger logger = LoggerFactory.getLogger(EnrichmentInterceptor.class);%0A%0A    @Test(enabled = false)%0A    public void testNonEmptySerialization() %7B%0A        byte%5B%5D message = %22hello%22.getBytes();%0A        String messageAsJsonString = %22%7B%5C%22message%5C%22:%5C%22aGVsbG8=%5C%22%7D%22;%0A%0A        try %7B%0A            // build an event from bytes with no extra_data and get its JSON string%0A            EnrichedEventBody fromBytes = new EnrichedEventBody(message);%0A            String jsonFromBytes = JSONStringSerializer.toJSONString(fromBytes);%0A%0A            logger.info(%22json fromBytes is: %22 + jsonFromBytes);%0A            logger.info(%22Original message is: %22 + messageAsJsonString);%0A            Assert.assertEquals(jsonFromBytes, messageAsJsonString);%0A%0A        %7D catch (IOException e) %7B%0A            e.printStackTrace();%0A            Assert.fail();%0A        %7D%0A    %7D%0A%7D%0A

Add tests