@Test
public void testDeserialize() throws Exception {

    StratioStreamingMessage message= StreamsHelper.getSampleMessage();
    String result= serializer.deserialize(message);
    Gson gson = new Gson();
    StratioStreamingMessage des= gson.fromJson(result, StratioStreamingMessage.class);
    assertEquals("Expected stream name not found", message.getStreamName(), des.getStreamName());
    assertEquals("Expected size not found", message.getColumns().size(), des.getColumns().size());
}