@Test
public void addQueryTest() {

    createBaseStream();
    streamOperationService.addQuery(STREAM_NAME_GOOD, "from " + STREAM_NAME_GOOD + " select * insert into "
            + INFERRED_STREAM_GOOD + " for current-events");
    Mockito.verify(streamStatusDao, VerificationModeFactory.times(2)).createInferredStream(Mockito.anyString(), Mockito.anyList());
    Assert.assertEquals("Expected value not found", 2, sm.getStreamDefinitions().size());
}