test.java

    @BeforeClass
    public void initClass() {
        dataAccess = new DataAccessImpl(session);

        ConfigurationService configurationService = new ConfigurationService() ;
        configurationService.init(rxSession);

        metricsService = new MetricsServiceImpl();
        metricsService.setDataAccess(dataAccess);
        metricsService.setConfigurationService(configurationService);
        metricsService.startUp(session, getKeyspace(), true, new MetricRegistry());

        jobScheduler = new TestScheduler(rxSession);
        long startTime = LocalDateTime.now(ZoneOffset.UTC)
                .with(DateTimeService.startOfNextOddHour())
                .toInstant(ZoneOffset.UTC).toEpochMilli() - 60000;
        jobScheduler.advanceTimeTo(startTime);

        jobScheduler.truncateTables(getKeyspace());

        jobsService = new JobsServiceImpl();
        jobsService.setSession(rxSession);
        jobsService.setScheduler(jobScheduler);
        jobsService.setMetricsService(metricsService);
    }