@@ -10,7 +10,7 @@ import (
1010
1111func TestScheduler (t * testing.T ) {
1212 sched := quartz .NewStdScheduler ()
13- var jobKeys [2 ]int
13+ var jobKeys [4 ]int
1414
1515 shellJob := quartz .NewShellJob ("ls -la" )
1616 shellJob .Description ()
@@ -21,13 +21,22 @@ func TestScheduler(t *testing.T) {
2121 curlJob .Description ()
2222 jobKeys [1 ] = curlJob .Key ()
2323
24+ errShellJob := quartz .NewShellJob ("ls -z" )
25+ jobKeys [2 ] = errShellJob .Key ()
26+
27+ errCurlJob , err := quartz .NewCurlJob (http .MethodGet , "http://" , "" , nil )
28+ assertEqual (t , err , nil )
29+ jobKeys [3 ] = errCurlJob .Key ()
30+
2431 sched .Start ()
2532 sched .ScheduleJob (shellJob , quartz .NewSimpleTrigger (time .Millisecond * 800 ))
2633 sched .ScheduleJob (curlJob , quartz .NewRunOnceTrigger (time .Millisecond ))
34+ sched .ScheduleJob (errShellJob , quartz .NewRunOnceTrigger (time .Millisecond ))
35+ sched .ScheduleJob (errCurlJob , quartz .NewSimpleTrigger (time .Millisecond * 800 ))
2736
2837 time .Sleep (time .Second )
2938 scheduledJobKeys := sched .GetJobKeys ()
30- assertEqual (t , scheduledJobKeys , []int {3059422767 })
39+ assertEqual (t , scheduledJobKeys , []int {3059422767 , 328790344 })
3140
3241 _ , err = sched .GetScheduledJob (jobKeys [0 ])
3342 if err != nil {
@@ -38,10 +47,15 @@ func TestScheduler(t *testing.T) {
3847 if err != nil {
3948 t .Fail ()
4049 }
41- assertEqual (t , sched .Queue .Len (), 0 )
50+
51+ scheduledJobKeys = sched .GetJobKeys ()
52+ assertEqual (t , scheduledJobKeys , []int {328790344 })
53+ assertEqual (t , sched .Queue .Len (), 1 )
4254
4355 sched .Clear ()
4456 sched .Stop ()
4557 assertEqual (t , shellJob .JobStatus , quartz .OK )
4658 assertEqual (t , curlJob .JobStatus , quartz .OK )
59+ assertEqual (t , errShellJob .JobStatus , quartz .FAILURE )
60+ assertEqual (t , errCurlJob .JobStatus , quartz .FAILURE )
4761}
0 commit comments