Dropwizard使用日晷计划作业无法访问会话

Question

我正在尝试使用dropwizer-日记本来安排工作。在我的预定工作中，我需要访问我的DAO。每当我计划的作业运行时，我都会收到以下错误...

org.hibernate.HibernateException: No session currently bound to execution context

我试图使用这个链接中描述的方法，https://github.com/timmolter/XDropWizard在注入全局对象或配置参数到作业一节中

这是我的申请代码：

public class ServiceApplication extends Application<OnboardingServiceConfiguration> {

    public static final Logger logger = LoggerFactory.getLogger(OnboardingServiceApplication.class);

    public static void main(String[] args) throws Exception {
        new OnboardingServiceApplication().run(args);
    }

    private final HibernateBundle<OnboardingServiceConfiguration> hibernate = new HibernateBundle<OnboardingServiceConfiguration>(com.rm.models.Application.class, EmailQueue.class) {
        @Override
        public DataSourceFactory getDataSourceFactory(OnboardingServiceConfiguration configuration) {
            return configuration.getDataSourceFactory();
        }
    };

    @Override
    public String getName() {
        return "onboarding";
    }

    @Override
    public void initialize(Bootstrap<OnboardingServiceConfiguration> bootstrap) {
        // add scheduled jobs
        bootstrap.addBundle(new SundialBundle<OnboardingServiceConfiguration>(){
            @Override
            public SundialConfiguration getSundialConfiguration(OnboardingServiceConfiguration configuration) {
                return configuration.getSundialConfiguration();
            }
        });
        //  to the database
        bootstrap.addBundle(hibernate);
    }

    @Override
    public void run(OnboardingServiceConfiguration configuration, Environment environment) throws Exception {
        // add health checks
        final HealthCheckResource resource = new HealthCheckResource(
                environment.healthChecks()
        );
        environment.jersey().register(resource);

        // configure DAOs for database management
        final ApplicationDAO applicationDAO = new ApplicationDAO(hibernate.getSessionFactory());
        final EmailDAO emailDAO = new EmailDAO(hibernate.getSessionFactory());


        logger.info("Package set for scheduled jobs: " + configuration.getSundialConfiguration().getAnnotatedJobsPackageName());
        environment.getApplicationContext().setAttribute("EmailDAO", emailDAO);
        environment.getApplicationContext().setAttribute("ApplicationDAO", applicationDAO);

        // add resources for REST API endpoints
        environment.jersey().register(new ApplicationResource());

        // setup environment to run scheduled jobs
        // more info and tutorial found at https://github.com/timmolter/dropwizard-sundial
        environment.admin().addTask(new LockSundialSchedulerTask());
        environment.admin().addTask(new UnlockSundialSchedulerTask());
        environment.admin().addTask(new RemoveJobTriggerTask());
        environment.admin().addTask(new AddCronJobTriggerTask());
        environment.admin().addTask(new StartJobTask());
        environment.admin().addTask(new StopJobTask());
        environment.admin().addTask(new RemoveJobTask());
        environment.admin().addTask(new AddJobTask());
    }


}

这是我预定的工作：

    @Override
public void doRun() throws JobInterruptException {
    this.logger = LoggerFactory.getLogger(EmailJobs.class);

    logger.info("Running Scheduled Tasks:");

    this.emailerService = new EmailerService((EmailDAO) SundialJobScheduler.getServletContext().getAttribute("EmailDAO"));
    this.applicationDAO = (ApplicationDAO) SundialJobScheduler.getServletContext().getAttribute("ApplicationDAO");

    List<Application> applications = applicationDAO.getAllForManagerIncompleteReminder();
}

我正在获取DAO，它们不是空的，但它们不绑定到任何会话。我该怎么解决这个问题？？

（PS，当我通过资源访问Hibernate会话时，它工作正常，只是不是计划的任务）

Answer 1

在ServiceApplication中，按如下方式实例化您的电子邮件服务，并将其添加到servletContext中。

// configure DAOs for database management
    final ApplicationDAO applicationDAO = new ApplicationDAO(hibernate.getSessionFactory());
    final EmailDAO emailDAO = new EmailDAO(hibernate.getSessionFactory());


    Class[] constructorParams = {EmailDAO.class};
    Object[] objectsParam = {emailDAO};
    EmailerService emailerService = new UnitOfWorkAwareProxyFactory(hibernate)
                .create(EmailerService.class, constructorParams, objectsParam);
    environment.getApplicationContext().setAttribute("EMAIL_SERVICE", emailerService);