@Test
@Ignore
public void testCreateCore() throws Exception {


    StratioStreamingMessage message= new StratioStreamingMessage(
                StreamsHelper.STREAM_NAME, Long.parseLong("1234567890"), StreamsHelper.COLUMNS);
        service.createCore(message);
}