Package com.gsitm.ustra.java.autoconfigure

Class UstraBatchWorkerAutoConfiguration

java.lang.Object
com.gsitm.ustra.java.autoconfigure.UstraBatchWorkerAutoConfiguration
@Configuration @ConditionalOnClass(com.gsitm.ustra.java.batch.worker.UstraBatchWorker.class) @AutoConfigureAfter(UstraBatchAutoConfiguration.class) @EnableConfigurationProperties(com.gsitm.ustra.java.batch.UstraBatchConfigProperties.class) @ConditionalOnExpression("\'${ustra.test.runtime:false}\' == \'false\'") public class UstraBatchWorkerAutoConfiguration extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    UstraBatchWorkerAutoConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.web.client.RestTemplate
    batchRestTemplate()
     
    com.gsitm.ustra.java.batch.worker.service.BatchService
    batchService(com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner taskRunner, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)
     
    com.gsitm.ustra.java.batch.data.repository.CommandRemoteRepository
    commandRemoteRepository(org.springframework.web.client.RestTemplate restTemplate)
     
    com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunnerObserver
    defaultUstraBatchTaskRunnerObserver(com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService workerTaskInstanceService)
     
    com.gsitm.ustra.java.batch.worker.config.LoggerConfig
    loggerConfig(com.gsitm.ustra.java.batch.UstraBatchConfigProperties ustraBatchConfigProperties)
     
    com.gsitm.ustra.java.batch.worker.config.LoggerInitializer
    loggerInitializer(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig, com.gsitm.ustra.java.batch.worker.config.LogPathGenerator logPathGenerator)
     
    com.gsitm.ustra.java.batch.worker.config.LogPathGenerator
    logPathGenerator(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig)
     
    String
    logPattern(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig)
     
    com.gsitm.ustra.java.batch.worker.connector.ManagerConnector
    managerConnector(org.springframework.web.client.RestTemplate restTemplate)
     
    com.gsitm.ustra.java.batch.data.repository.SimpleFileRepository
    simpleFileRepository()
     
    com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService
    taskInstanceService(com.gsitm.ustra.java.batch.worker.config.LogPathGenerator logPathGenerator, com.gsitm.ustra.java.batch.data.repository.SimpleFileRepository simpleFileRepository, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)
     
    com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner
    taskRunner()
     
    com.gsitm.ustra.java.batch.worker.config.UstraBatchTaskRunnerInitializer
    ustraBatchTaskRunnerInitializer(com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner ustraBatchTaskRunner, com.gsitm.ustra.java.batch.runner.UstraBatchWorkerContextObserver ustraBatchWorkerContextObserver, com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunnerObserver defaultUstraBatchTaskRunnerObserver)
     
    com.gsitm.ustra.java.batch.runner.UstraBatchWorkerContextObserver
    ustraBatchWorkerContextObserver(com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)
     
    com.gsitm.ustra.java.batch.worker.WorkerApp
    workerApp(com.gsitm.ustra.java.batch.worker.service.WorkerCommandService workerCommandService, com.gsitm.ustra.java.batch.worker.service.BatchService batchService, com.gsitm.ustra.java.batch.worker.service.WorkerMaintainService workerMaintainService)
     
    com.gsitm.ustra.java.batch.worker.service.WorkerCommandService
    workerCommandService(com.gsitm.ustra.java.batch.data.repository.WorkerHolder workerHolder, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)
     
    ThreadPoolExecutor
    workerExecutor()
     
    com.gsitm.ustra.java.batch.data.repository.WorkerHolder
    workerHolder(com.gsitm.ustra.java.batch.UstraBatchConfigProperties ustraBatchConfigProperties)
     
    com.gsitm.ustra.java.batch.worker.service.WorkerMaintainService
    workerMaintainService(com.gsitm.ustra.java.batch.data.repository.WorkerHolder workerHolder, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)
     
    com.gsitm.ustra.java.batch.worker.controller.WorkerTaskInstanceController
    workerTaskInstanceController(com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService workerTaskInstanceService)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • UstraBatchWorkerAutoConfiguration

      public UstraBatchWorkerAutoConfiguration()

  • Method Details

    • workerCommandService

      @Bean public com.gsitm.ustra.java.batch.worker.service.WorkerCommandService workerCommandService(com.gsitm.ustra.java.batch.data.repository.WorkerHolder workerHolder, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)

    • workerApp

      @Bean public com.gsitm.ustra.java.batch.worker.WorkerApp workerApp(com.gsitm.ustra.java.batch.worker.service.WorkerCommandService workerCommandService, com.gsitm.ustra.java.batch.worker.service.BatchService batchService, com.gsitm.ustra.java.batch.worker.service.WorkerMaintainService workerMaintainService)

    • batchRestTemplate

      @Bean @Qualifier("batchRestTemplate") public org.springframework.web.client.RestTemplate batchRestTemplate()

    • taskInstanceService

      @Bean public com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService taskInstanceService(com.gsitm.ustra.java.batch.worker.config.LogPathGenerator logPathGenerator, com.gsitm.ustra.java.batch.data.repository.SimpleFileRepository simpleFileRepository, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)

    • commandRemoteRepository

      @Bean public com.gsitm.ustra.java.batch.data.repository.CommandRemoteRepository commandRemoteRepository(@Qualifier("batchRestTemplate") org.springframework.web.client.RestTemplate restTemplate)

    • workerHolder

      @Bean public com.gsitm.ustra.java.batch.data.repository.WorkerHolder workerHolder(com.gsitm.ustra.java.batch.UstraBatchConfigProperties ustraBatchConfigProperties)

    • ustraBatchWorkerContextObserver

      @Bean public com.gsitm.ustra.java.batch.runner.UstraBatchWorkerContextObserver ustraBatchWorkerContextObserver(com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)

    • taskRunner

      @Bean public com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner taskRunner()

    • defaultUstraBatchTaskRunnerObserver

      @Bean public com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunnerObserver defaultUstraBatchTaskRunnerObserver(@Autowired(required=false) com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService workerTaskInstanceService)

    • workerExecutor

      @Bean public ThreadPoolExecutor workerExecutor()

    • loggerConfig

      @Bean public com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig(com.gsitm.ustra.java.batch.UstraBatchConfigProperties ustraBatchConfigProperties)

    • logPattern

      @Bean public String logPattern(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig)

    • logPathGenerator

      @Bean public com.gsitm.ustra.java.batch.worker.config.LogPathGenerator logPathGenerator(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig)

    • simpleFileRepository

      @Bean public com.gsitm.ustra.java.batch.data.repository.SimpleFileRepository simpleFileRepository()

    • workerTaskInstanceController

      @Bean public com.gsitm.ustra.java.batch.worker.controller.WorkerTaskInstanceController workerTaskInstanceController(com.gsitm.ustra.java.batch.worker.service.WorkerTaskInstanceService workerTaskInstanceService)

    • batchService

      @Bean public com.gsitm.ustra.java.batch.worker.service.BatchService batchService(com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner taskRunner, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)

    • managerConnector

      @Bean public com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector(@Qualifier("batchRestTemplate") org.springframework.web.client.RestTemplate restTemplate)

    • workerMaintainService

      @Bean public com.gsitm.ustra.java.batch.worker.service.WorkerMaintainService workerMaintainService(com.gsitm.ustra.java.batch.data.repository.WorkerHolder workerHolder, com.gsitm.ustra.java.batch.data.repository.ManagerRepository managerRepository, com.gsitm.ustra.java.batch.worker.connector.ManagerConnector managerConnector)

    • loggerInitializer

      @Bean public com.gsitm.ustra.java.batch.worker.config.LoggerInitializer loggerInitializer(com.gsitm.ustra.java.batch.worker.config.LoggerConfig loggerConfig, com.gsitm.ustra.java.batch.worker.config.LogPathGenerator logPathGenerator)

    • ustraBatchTaskRunnerInitializer

      @Bean public com.gsitm.ustra.java.batch.worker.config.UstraBatchTaskRunnerInitializer ustraBatchTaskRunnerInitializer(com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunner ustraBatchTaskRunner, com.gsitm.ustra.java.batch.runner.UstraBatchWorkerContextObserver ustraBatchWorkerContextObserver, com.gsitm.ustra.java.batch.runner.UstraBatchTaskRunnerObserver defaultUstraBatchTaskRunnerObserver)