### Question:
QueryProcess implements ConnectorProcess { @Override public void endQuery() throws ExecutionException { queryExecutor.endQuery(StreamUtil.createStreamName(project.getTableName()), connection); } QueryProcess(String queryId, Project project, IResultHandler resultHandler,
                    Connection<IStratioStreamingAPI> connection); @TimerJ void run(); @Override void endQuery(); @Override Project getProject();  }### Answer:
@Test public void endQueryTest() throws Exception { Whitebox.setInternalState(queryProcess, "queryExecutor", connectorQueryExecutor); TableName tableName = new TableName(CATALOG, TABLE); when(PROJECT.getTableName()).thenReturn(tableName); queryProcess.endQuery(); verify(connectorQueryExecutor, times(1)).endQuery(CATALOG + "_" + TABLE, CONNECTION); }