@Configuration public class ClusterSchedulerConfiguration extends Object
| 构造器和说明 |
|---|
ClusterSchedulerConfiguration() |
| 限定符和类型 | 方法和说明 |
|---|---|
TaskClient |
clusterTaskClient(ClusterManager clusterManager,
TaskFactory taskFactory,
LockManager lockManager,
SchedulerFactory schedulerFactory,
TaskScheduler taskScheduler,
JobRepository jobRepository,
TaskRepository taskRepository) |
ClusterTaskSchedulerBean |
clusterTaskScheduler(ClusterManager clusterManager,
ScheduledExecutorService executorService,
SchedulerFactory schedulerFactory,
TaskWorkerManager taskWorkerManager,
EventPublisher eventPublisher,
TaskRepository taskRepository,
TaskFactory taskFactory,
JobRepository jobRepository,
LockManager lockManager,
TaskProperties taskProperties,
ScheduleHistoryRepository scheduleHistoryRepository) |
@Bean(destroyMethod="shutdownNow") public ClusterTaskSchedulerBean clusterTaskScheduler(ClusterManager clusterManager, ScheduledExecutorService executorService, SchedulerFactory schedulerFactory, TaskWorkerManager taskWorkerManager, EventPublisher eventPublisher, TaskRepository taskRepository, TaskFactory taskFactory, JobRepository jobRepository, LockManager lockManager, TaskProperties taskProperties, ScheduleHistoryRepository scheduleHistoryRepository)
@Bean(initMethod="startup",
destroyMethod="shutdown")
@Primary
public TaskClient clusterTaskClient(ClusterManager clusterManager,
TaskFactory taskFactory,
LockManager lockManager,
SchedulerFactory schedulerFactory,
TaskScheduler taskScheduler,
JobRepository jobRepository,
TaskRepository taskRepository)
Copyright © 2018. All rights reserved.