public Command create(
      final ConfiguredStatement<? extends Statement> statement,
      final KsqlExecutionContext context) {
    return create(statement, context.getServiceContext(), context);
  }
@Test
  public void shouldValidateResumeQuery() {
    // Given:
    givenResume();

    // When:
    commandFactory.create(configuredStatement, executionContext);

    // Then:
    verify(executionContext).getPersistentQuery(QUERY_ID);
    verify(query1).resume();
  }