@Test
public void testReplicateLogEntries() throws IOException {

    byte[] rowKey = Bytes.toBytes("rowkey");
    byte[] payloadData = Bytes.toBytes("payload");
    WAL.Entry hlogEntry = createHlogEntry(TABLE_NAME, new KeyValue(rowKey, DATA_COLFAM,
            PAYLOAD_QUALIFIER, payloadData));
    replicateWALEntry(new WAL.Entry[]{hlogEntry});
    SepEvent expectedSepEvent = SepEvent.create(TABLE_NAME, rowKey,
            hlogEntry.getEdit().getCells(), payloadData);
    verify(eventListener).processEvents(Lists.newArrayList(expectedSepEvent));
}