@Test
public void testDeserializeList() throws Exception {

    List<Event> events= new ArrayList<Event>();
    Object[] values = new Object[3];
    values[0]= new ColumnNameTypeValue("name", ColumnType.STRING, "test");
    values[1]= new ColumnNameTypeValue("value", ColumnType.INTEGER, 10);
    values[2]= new ColumnNameTypeValue("enabled", ColumnType.BOOLEAN, true);
    events.add(new InEvent(StreamsHelper.STREAM_NAME, System.currentTimeMillis(), values));
    values = new Object[3];
    values[0]= new ColumnNameTypeValue("name", ColumnType.STRING, "test2");
    values[1]= new ColumnNameTypeValue("value", ColumnType.INTEGER, 11);
    values[2]= new ColumnNameTypeValue("enabled", ColumnType.BOOLEAN, false);
    events.add(new InEvent(StreamsHelper.STREAM_NAME, System.currentTimeMillis(), values));
    List<StratioStreamingMessage> messages= serializer.deserialize(events);
    assertEquals("Expected value not found", 2, messages.size());
}