@Test
public void testReceive() throws Exception {

    StratioStreamingMessage message= StreamsHelper.getSampleMessage();
    Event event= javaToSiddhiSerializer.serialize(message);
    Event[] inEvents= {event};
    Event[] removeEvents= {event};
    Exception ex= null;
    try {
        cbk.receive(123456789L, inEvents, removeEvents);
    } catch (Exception e) {ex= e;}
    assertNull("Unexpected exception found", ex);
}