File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
src/main/java/org/dataloader/registries Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -257,7 +257,7 @@ public static class Builder {
257257 private final Map <String , DataLoader <?, ?>> dataLoaders = new LinkedHashMap <>();
258258 private final Map <DataLoader <?, ?>, DispatchPredicate > dataLoaderPredicates = new LinkedHashMap <>();
259259 private DispatchPredicate dispatchPredicate = DispatchPredicate .DISPATCH_ALWAYS ;
260- private ScheduledExecutorService scheduledExecutorService = Executors . newSingleThreadScheduledExecutor () ;
260+ private ScheduledExecutorService scheduledExecutorService ;
261261 private Duration schedule = Duration .ofMillis (10 );
262262 private boolean tickerMode = false ;
263263
@@ -348,6 +348,9 @@ public Builder tickerMode(boolean tickerMode) {
348348 * @return the newly built {@link ScheduledDataLoaderRegistry}
349349 */
350350 public ScheduledDataLoaderRegistry build () {
351+ if (scheduledExecutorService == null ) {
352+ scheduledExecutorService = Executors .newSingleThreadScheduledExecutor ();
353+ }
351354 return new ScheduledDataLoaderRegistry (this );
352355 }
353356 }
You can’t perform that action at this time.
0 commit comments