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


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