@Bean
    public Scheduler scheduler(ConductorProperties properties) {
        ThreadFactory threadFactory =
                new BasicThreadFactory.Builder()
                        .namingPattern("event-queue-poll-scheduler-thread-%d")
                        .build();
        Executor executorService =
                Executors.newFixedThreadPool(
                        properties.getEventQueueSchedulerPollThreadCount(), threadFactory);

        return Schedulers.from(executorService);
    }
Used by some {@link com.netflix.conductor.core.events.queue.ObservableQueue} implementations.

@see com.netflix.conductor.core.events.queue.ConductorObservableQueue
core/src/main/java/com/netflix/conductor/core/config/SchedulerConfiguration.java