Skip to content

Commit 41d3021

Browse files
Move application of IndirectedDelayedExecutor to Engine build time
1 parent 4017cf0 commit 41d3021

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/com/linkedin/parseq/EngineBuilder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public EngineBuilder setTaskExecutor(final Executor taskExecutor)
7777
public EngineBuilder setTimerScheduler(final DelayedExecutor timerScheduler)
7878
{
7979
ArgumentUtil.notNull(timerScheduler, "timerScheduler");
80-
_timerScheduler = new IndirectDelayedExecutor(timerScheduler);
80+
_timerScheduler = timerScheduler;
8181
return this;
8282
}
8383

@@ -143,7 +143,7 @@ public Engine build()
143143
}
144144
Engine engine = new Engine(
145145
_taskExecutor,
146-
_timerScheduler,
146+
new IndirectDelayedExecutor(_timerScheduler),
147147
_loggerFactory != null ? _loggerFactory : LoggerFactory.getILoggerFactory(),
148148
_properties
149149
);

0 commit comments

Comments
 (0)