@Test
public void testExecute() {

    String ent1 = "Jane Doe";
    String ent2 = "Mount Everest";
    Message msg = new Message(DateTime.now(), "jane", "u1",
                              String.format("Today, %s is going to climb %s", ent1, ent2),
                              "r1", MessageType.MESSAGE);
    FatMessage fatMessage = new FatMessage(msg, user, room);
    List<Object> values = Lists.newArrayList(fatMessage);
    Tuple input = new TupleImpl(context, values, 0, "stream-id");
    underTest.execute(input, collector);
    verify(collector, times(2)).emit(any(Values.class));
}