package com.cloudera.flume.core;
import java.io.IOException;
import com.cloudera.flume.handlers.debug.MemorySinkSource;
import org.junit.Test;
import static org.junit.Assert.assertEquals;
@Test
MemorySinkSource mem = new MemorySinkSource();
EventSink format = new FormatterDecorator<EventSink>(mem, "test %{body}");
Event e = new EventImpl("content".getBytes());
e.set("attr1", "value".getBytes());
format.open();
format.append(e);
format.close();
mem.open();
Event e2 = mem.next();
assertEquals("test content", new String(e2.getBody()));
assertEquals("value", Attributes.readString(e2, "attr1"));
}
}