StreamOperationServiceWithoutMetrics { public void dropStream(String streamName) { Map<String, QueryDTO> attachedQueries = streamStatusDao.get(streamName).getAddedQueries(); for (String queryId : attachedQueries.keySet()) { siddhiManager.removeQuery(queryId); } siddhiManager.removeStream(streamName); streamStatusDao.remove(streamName); } StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
                                                CallbackService callbackService);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
            CallbackService callbackService, ConfigurationContext configurationContext);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
        CallbackService callbackService, DroolsConnectionContainer droolsConnectionContainer, ConfigurationContext configurationContext); void createInternalStream(String streamName, List<ColumnNameTypeValue> columns); void createStream(String streamName, List<ColumnNameTypeValue> columns); boolean streamExist(String streamName); boolean isUserDefined(String streamName); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns, Boolean raiseException); void dropStream(String streamName); String addQuery(String streamName, String queryString); void removeQuery(String queryId, String streamName); boolean queryIdExists(String streamName, String queryId); boolean queryRawExists(String streamName, String queryRaw); Boolean columnExists(String streamName, String columnName); void enableAction(String streamName, StreamAction action); void disableAction(String streamName, StreamAction action); boolean isActionEnabled(String streamName, StreamAction action); void enableEngineAction(String streamName, EngineActionType engineActionType, Map<String, Object>
            engineActionParams); void disableEngineAction(String streamName, EngineActionType engineActionType); List<StratioStreamingMessage> list(); void send(String streamName, List<ColumnNameTypeValue> columns);  }
@Test public void testDropStream() throws Exception { streamOperationsService.createStream(StreamsHelper.STREAM_NAME, StreamsHelper.COLUMNS); assertTrue(streamOperationsService.streamExist(StreamsHelper.STREAM_NAME)); String queryId= streamOperationsService.addQuery(StreamsHelper.STREAM_NAME, StreamsHelper.QUERY); streamOperationsService.dropStream(StreamsHelper.STREAM_NAME); assertFalse("Expected false not found", streamOperationsService.streamExist(StreamsHelper.STREAM_NAME)); }