Package com.almis.awe.scheduler.autoconfigure

Class SchedulerConfig

java.lang.Object
com.almis.awe.scheduler.autoconfigure.SchedulerConfig
@Configuration @EnableFeignClients(clients=RemoteScheduler.class) @EnableConfigurationProperties(SchedulerConfigProperties.class) public class SchedulerConfig extends Object
Scheduler module configuration

  • Constructor Details

  • Method Details

    • jobRegistryBeanPostProcessorRemover

      @Bean public static org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor jobRegistryBeanPostProcessorRemover()
      Modify bean registration jobRegistryBeanPostProcessor to avoid some WARN messages when the application is starting
      Returns:
      Bean post processor

    • scheduler

      @Bean public org.quartz.Scheduler scheduler(org.springframework.scheduling.quartz.SchedulerFactoryBean factory)
      Define Scheduler
      Returns:
      Scheduler

    • restTemplate

      @Bean public org.springframework.web.client.RestTemplate restTemplate()
      Define RestTemplate
      Returns:
      rest template

    • runtime

      @Bean public Runtime runtime()
      Define Runtime
      Returns:
      Runtime

    • ftpClient

      @Bean @Scope("prototype") public org.apache.commons.net.ftp.FTPClient ftpClient()
      Define FTP Client
      Returns:
      FTP Client

    • fileClient

      @Bean @Scope("prototype") public FileClient fileClient()
      Define FileClient
      Returns:
      FileClient

    • schedulerService

      @Bean public SchedulerService schedulerService(TaskDAO taskDAO, SchedulerDAO schedulerDAO, CalendarDAO calendarDAO)
      Define Scheduler service
      Returns:
      Scheduler service

    • remoteSchedulerService

      @Bean public RemoteSchedulerService remoteSchedulerService(SchedulerService schedulerService, RemoteScheduler remoteScheduler, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
      Define Scheduler service
      Returns:
      Scheduler service

    • taskService

      @Bean public TaskService taskService(QueryService queryService, QueryUtil queryUtil, TaskDAO taskDAO)
      Define Task service
      Returns:
      Task service

    • timeoutService

      @Bean public ExecutionService timeoutService(org.quartz.Scheduler scheduler)
      Define Scheduler service
      Returns:
      Scheduler service

    • maintainJobService

      @Bean public MaintainJobService maintainJobService(ExecutionService executionService, MaintainService maintainService, QueryUtil queryUtil, TaskDAO taskDAO, org.springframework.context.ApplicationEventPublisher eventPublisher, com.fasterxml.jackson.databind.ObjectMapper mapper, org.springframework.web.client.RestTemplate restTemplate)
      Define Maintain job service
      Returns:
      Scheduler service

    • commandJobService

      @Bean public CommandJobService commandJobService(ExecutionService executionService, MaintainService maintainService, QueryUtil queryUtil, TaskDAO taskDAO, org.springframework.context.ApplicationEventPublisher eventPublisher, CommandDAO commandDAO)
      Define Command job service
      Returns:
      Scheduler service

    • schedulerReportService

      @Bean public SchedulerReportService schedulerReportService()
      Scheduler report service
      Returns:
      Scheduler report service

    • reportJobService

      @Bean public ReportJobService reportJobService(SchedulerReportService schedulerReportService)
      Report job service
      Parameters:
      schedulerReportService - Scheduler report service
      Returns:
      Report job service

    • progressJob

      @Bean @Scope("prototype") public ProgressJob progressJob(org.springframework.context.ApplicationEventPublisher eventPublisher)
      Define progress job
      Returns:
      Scheduler job

    • timeoutJob

      @Bean @Scope("prototype") public TimeoutJob timeoutJob()
      Define timeout job
      Returns:
      Scheduler job

    • maintainJob

      @Bean @Scope("prototype") public MaintainJob maintainJob(MaintainJobService jobService)
      Define Maintain job
      Returns:
      Scheduler job

    • commandJob

      @Bean @Scope("prototype") public CommandJob commandJob(CommandJobService jobService)
      Define Command job
      Returns:
      Scheduler job

    • maintainReportService

      @Bean public SchedulerMaintainReportService maintainReportService(QueryUtil queryUtil, MaintainService maintainService)
      Define maintain report service
      Returns:
      Maintain report service

    • schedulerNoneReportService

      @Bean public SchedulerNoneReport schedulerNoneReportService()
      Define none report service
      Returns:
      None report service

    • emailReportService

      @Bean public SchedulerEmailReportService emailReportService(QueryUtil queryUtil, MaintainService maintainService, QueryService queryService, com.fasterxml.jackson.databind.ObjectMapper mapper)
      Define email report job
      Returns:
      Email report service

    • broadcastReportService

      @Bean public SchedulerBroadcastReportService broadcastReportService(BroadcastService broadcastService)
      Define broadcast report service
      Returns:
      Broadcast report service

    • reportServiceFactory

      @Bean public ReportServiceFactory reportServiceFactory(List<ISchedulerReportService> schedulerReportServiceList)
      Report service factory
      Parameters:
      schedulerReportServiceList - Scheduler report service list
      Returns:
      Report service factory bean

    • databaseDAO

      @Bean public DatabaseDAO databaseDAO(QueryService queryService)
      Database Data Object Access
      Returns:
      Database DAO

    • calendarDAO

      @Bean public CalendarDAO calendarDAO(org.quartz.Scheduler scheduler, QueryService queryService, QueryUtil queryUtil, com.fasterxml.jackson.databind.ObjectMapper mapper)
      Calendar Data Object Access
      Returns:
      Calendar DAO

    • schedulerDAO

      @Bean public SchedulerDAO schedulerDAO(org.quartz.Scheduler scheduler, CalendarDAO calendarDAO, TaskService taskService, SchedulerTriggerListener triggerListener, SchedulerJobListener jobListener)
      Scheduler Data Object Access
      Returns:
      Scheduler DAO

    • taskDAO

      @Bean public TaskDAO taskDAO(org.quartz.Scheduler scheduler, QueryService queryService, MaintainService maintainService, QueryUtil queryUtil, CalendarDAO calendarDAO, ServerDAO serverDAO, FileChecker fileChecker)
      Task Data Object Access
      Returns:
      Task DAO

    • fileDAO

      @Bean public FileDAO fileDAO(MaintainService maintainService, QueryUtil queryUtil)
      File Data Object Access
      Returns:
      File DAO

    • serverDAO

      @Bean public ServerDAO serverDAO(QueryService queryService, QueryUtil queryUtil)
      Server Data Object Access
      Returns:
      File DAO

    • commandDAO

      @Bean public CommandDAO commandDAO(Runtime runtime)
      Server Data Object Access
      Returns:
      File DAO

    • fileChecker

      @Bean public FileChecker fileChecker(FTPFileChecker ftpFileChecker, FolderFileChecker folderFileChecker)
      Define file checker
      Returns:
      File checker

    • ftpFileChecker

      @Bean public FTPFileChecker ftpFileChecker(FileDAO fileDAO, org.apache.commons.net.ftp.FTPClient ftpClient)
      Define ftp file checker
      Returns:
      FTP File checker

    • folderFileChecker

      @Bean public FolderFileChecker folderFileChecker(FileDAO fileDAO, FileClient fileClient)
      Define folder file checker
      Returns:
      Folder File checker

    • schedulerTriggerListener

      @Bean public SchedulerTriggerListener schedulerTriggerListener(TaskDAO taskDAO)
      LISTENERS

    • schedulerJobListener

      @Bean public SchedulerJobListener schedulerJobListener(org.springframework.context.ApplicationEventPublisher eventPublisher)

    • schedulerEventListener

      @Bean public SchedulerEventListener schedulerEventListener(BroadcastService broadcastService, AweConnectionTracker connectionTracker, TaskDAO taskDAO)