Skip to content

Commit fbe973b

Browse files
committed
Add timezone support to CronnableSchedule
1 parent 9d914c3 commit fbe973b

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

x-pack/plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/trigger/schedule/CronnableSchedule.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,14 @@
1111
import java.util.Arrays;
1212
import java.util.Comparator;
1313
import java.util.Objects;
14+
import java.util.TimeZone;
1415

1516
public abstract class CronnableSchedule implements Schedule {
1617

1718
private static final Comparator<Cron> CRON_COMPARATOR = Comparator.comparing(Cron::expression);
1819

1920
protected final Cron[] crons;
21+
private TimeZone timeZone;
2022

2123
CronnableSchedule(String... expressions) {
2224
this(crons(expressions));
@@ -28,6 +30,17 @@ private CronnableSchedule(Cron... crons) {
2830
Arrays.sort(crons, CRON_COMPARATOR);
2931
}
3032

33+
protected void setTimeZone(TimeZone timeZone) {
34+
this.timeZone = timeZone;
35+
for (Cron cron : crons) {
36+
cron.setTimeZone(timeZone);
37+
}
38+
}
39+
40+
public TimeZone getTimeZone() {
41+
return timeZone;
42+
}
43+
3144
@Override
3245
public long nextScheduledTimeAfter(long startTime, long time) {
3346
assert time >= startTime;

0 commit comments

Comments
 (0)