@Test
public void testReplicateLogEntries_MultipleKeyValuesForSingleRow() throws Exception {

    byte[] rowKey = Bytes.toBytes("rowKey");
    Cell kvA = new KeyValue(rowKey, DATA_COLFAM, PAYLOAD_QUALIFIER, Bytes.toBytes("A"));
    Cell kvB = new KeyValue(rowKey, DATA_COLFAM, PAYLOAD_QUALIFIER, Bytes.toBytes("B"));
    WAL.Entry entry = createHlogEntry(TABLE_NAME, kvA, kvB);
    replicateWALEntry(new WAL.Entry[]{entry});
    // We should get the first payload in our event (and the second one will be ignored, although the KeyValue will
    // be present in the event
    SepEvent expectedEvent = SepEvent.create(TABLE_NAME, rowKey, Lists.newArrayList(kvA, kvB),
            Bytes.toBytes("A"));
    verify(eventListener).processEvents(Lists.newArrayList(expectedEvent));
}