@Test public void scheduler() throws Exception { assertThat(store.scheduler()).isNotNull(); }
@Override protected Scheduler scheduler() { long delay = 1L; if (properties.containsKey("syncInterval")) { delay = Math.max(Long.parseLong(properties.get("syncInterval")), delay); } return Scheduler.newFixedDelaySchedule(0L, delay, TimeUnit.SECONDS); }
ElasticSearchStore extends AbstractScheduledService implements AutoCloseable { @Override protected Scheduler scheduler() { long delay = 1L; if (properties.containsKey("syncInterval")) { delay = Math.max(Long.parseLong(properties.get("syncInterval")), delay); } return Scheduler.newFixedDelaySchedule(0L, delay, TimeUnit.SECONDS); } }
ElasticSearchStore extends AbstractScheduledService implements AutoCloseable { @Override protected Scheduler scheduler() { long delay = 1L; if (properties.containsKey("syncInterval")) { delay = Math.max(Long.parseLong(properties.get("syncInterval")), delay); } return Scheduler.newFixedDelaySchedule(0L, delay, TimeUnit.SECONDS); } @Inject  ElasticSearchStore(); @VisibleForTesting  ElasticSearchStore(Map<String, String> properties, JestClient client); }
ElasticSearchStore extends AbstractScheduledService implements AutoCloseable { @Override protected Scheduler scheduler() { long delay = 1L; if (properties.containsKey("syncInterval")) { delay = Math.max(Long.parseLong(properties.get("syncInterval")), delay); } return Scheduler.newFixedDelaySchedule(0L, delay, TimeUnit.SECONDS); } @Inject  ElasticSearchStore(); @VisibleForTesting  ElasticSearchStore(Map<String, String> properties, JestClient client); @PostConstruct void init(); @Override @PreDestroy void close(); }
ElasticSearchStore extends AbstractScheduledService implements AutoCloseable { @Override protected Scheduler scheduler() { long delay = 1L; if (properties.containsKey("syncInterval")) { delay = Math.max(Long.parseLong(properties.get("syncInterval")), delay); } return Scheduler.newFixedDelaySchedule(0L, delay, TimeUnit.SECONDS); } @Inject  ElasticSearchStore(); @VisibleForTesting  ElasticSearchStore(Map<String, String> properties, JestClient client); @PostConstruct void init(); @Override @PreDestroy void close();  }