CassandraSchedulerStore implements SchedulerStore { @Override public Completable deleteSystemSelector(String id) { return StoreUtils.remove( session, deleteSystemSelectorStatement, id ).timeout(TIMEOUT_MS, TimeUnit.MILLISECONDS); } @Inject  CassandraSchedulerStore(CassandraStoreConfiguration configuration,
                                   @Named(SCHEDULER_SANITIZER) EntitySanitizer entitySanitizer,
                                   Session session);  CassandraSchedulerStore(CassandraStoreConfiguration configuration,
                                   @Named(SCHEDULER_SANITIZER) EntitySanitizer entitySanitizer,
                                   Session session,
                                   ObjectMapper mapper); @Activator void enterActiveMode(); @Override Observable<SystemSelector> retrieveSystemSelectors(); @Override Completable storeSystemSelector(SystemSelector systemSelector); @Override Completable deleteSystemSelector(String id);  }
@Test public void testDeleteSystemSelector() { List<SystemSelector> systemSelectors = CollectionsExt.merge( SchedulerGenerator.shouldSystemSelectors().toList(4), SchedulerGenerator.mustSystemSelectors().toList(3) ); SchedulerStore schedulerStore = createSchedulerStore(); systemSelectors.forEach(systemSelector -> schedulerStore.storeSystemSelector(systemSelector).await()); assertThat(schedulerStore.retrieveSystemSelectors().toList().toBlocking().first()).hasSize(7); String idToDelete = systemSelectors.get(0).getId(); schedulerStore.deleteSystemSelector(idToDelete).await(); assertThat(schedulerStore.retrieveSystemSelectors().toList().toBlocking().first()).hasSize(6); }