@Test
public void testDeserialize() throws Exception {

    Object[] values = new Object[5];
    values[0]= new ColumnNameTypeValue("name", ColumnType.STRING, "test");
    values[1]= new ColumnNameTypeValue("value", ColumnType.INTEGER, 10);
    values[2]= new ColumnNameTypeValue("enabled", ColumnType.BOOLEAN, true);
    values[3]= new ColumnNameTypeValue("numberl", ColumnType.LONG, 123L);
    values[4]= new ColumnNameTypeValue("numberf", ColumnType.FLOAT, 13f);
    Event event= new InEvent(StreamsHelper.STREAM_NAME, System.currentTimeMillis(), values);
    StratioStreamingMessage message= serializer.deserialize(event);
    assertEquals("Expected value not found", "test",
            ((ColumnNameTypeValue) message.getColumns().get(0).getValue()).getValue());
    assertEquals("Expected value not found",10,
            ((ColumnNameTypeValue) message.getColumns().get(1).getValue()).getValue());
    assertEquals("Expected value not found", true,
            ((ColumnNameTypeValue) message.getColumns().get(2).getValue()).getValue());
}