@@ -17,7 +17,8 @@ import app.softnetwork.scheduler.persistence.query.Entity2SchedulerProcessorStre
1717import org .scalatest .Suite
1818import org .slf4j .{Logger , LoggerFactory }
1919
20- trait SchedulerTestKit extends SchedulerGuardian with InMemoryPersistenceTestKit { _ : Suite =>
20+ trait SchedulerTestKit extends SchedulerGuardian with InMemoryPersistenceTestKit {
21+ _ : Suite =>
2122
2223 /** @return
2324 * roles associated with this node
@@ -38,16 +39,24 @@ trait SchedulerTestKit extends SchedulerGuardian with InMemoryPersistenceTestKit
3839 log.info(tag)
3940 }
4041
41- val probeScheduleAdded : TestProbe [ScheduleAdded ] = createTestProbe[ScheduleAdded ]()
42- subscribeProbe(probeScheduleAdded)
42+ lazy val probeScheduleAdded : TestProbe [ScheduleAdded ] = createTestProbe[ScheduleAdded ]()
4343
44- val probeScheduleRemoved : TestProbe [ScheduleRemoved ] = createTestProbe[ScheduleRemoved ]()
45- subscribeProbe(probeScheduleRemoved)
44+ lazy val probeScheduleRemoved : TestProbe [ScheduleRemoved ] = createTestProbe[ScheduleRemoved ]()
4645
47- val probeCronTabAdded : TestProbe [CronTabAdded ] = createTestProbe[CronTabAdded ]()
48- subscribeProbe(probeCronTabAdded)
46+ lazy val probeCronTabAdded : TestProbe [CronTabAdded ] = createTestProbe[CronTabAdded ]()
4947
50- val probeCronTabRemoved : TestProbe [CronTabRemoved ] = createTestProbe[CronTabRemoved ]()
51- subscribeProbe(probeCronTabRemoved)
48+ lazy val probeCronTabRemoved : TestProbe [CronTabRemoved ] = createTestProbe[CronTabRemoved ]()
49+
50+ def subscribeSchedulerProbes (): Unit = {
51+ subscribeProbe(probeScheduleAdded)
52+ subscribeProbe(probeScheduleRemoved)
53+ subscribeProbe(probeCronTabAdded)
54+ subscribeProbe(probeCronTabRemoved)
55+ }
56+
57+ override def beforeAll (): Unit = {
58+ super .beforeAll()
59+ subscribeSchedulerProbes()
60+ }
5261
5362}
0 commit comments