• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java TaskExplorer类的典型用法和代码示例

java 2次浏览

本文整理汇总了Java中org.springframework.cloud.task.repository.TaskExplorer的典型用法代码示例。如果您正苦于以下问题:Java TaskExplorer类的具体用法?Java TaskExplorer怎么用?Java TaskExplorer使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

TaskExplorer类属于org.springframework.cloud.task.repository包,在下文中一共展示了TaskExplorer类的38个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: taskConfigurer

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskConfigurer taskConfigurer() {
	return new TaskConfigurer() {
		@Override
		public TaskRepository getTaskRepository() {
			return null;
		}

		@Override
		public PlatformTransactionManager getTransactionManager() {
			return null;
		}

		@Override
		public TaskExplorer getTaskExplorer() {
			return mock(TaskExplorer.class);
		}

		@Override
		public DataSource getTaskDataSource() {
			return mock(DataSource.class);
		}
	};
}
 

开发者ID:spring-cloud-task-app-starters,
项目名称:composed-task-runner,
代码行数:25,
代码来源:ComposedTaskRunnerStepFactoryTests.java

示例2: testMultipleDataSources

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testMultipleDataSources() {
	this.applicationContext = SpringApplication.run(new Class[] {JobConfigurationMultipleDataSources.class,
			PropertyPlaceholderAutoConfiguration.class,
			EmbeddedDataSourceConfiguration.class,
			BatchAutoConfiguration.class,
			TaskBatchAutoConfiguration.class}, ARGS);

	TaskExplorer taskExplorer = this.applicationContext.getBean(TaskExplorer.class);

	Page<TaskExecution> page = taskExplorer.findTaskExecutionsByName("application", new PageRequest(0, 1));

	Set<Long> jobExecutionIds = taskExplorer.getJobExecutionIdsByTaskExecutionId(page.iterator().next().getExecutionId());

	assertEquals(1, jobExecutionIds.size());
	assertEquals(1, taskExplorer.getTaskExecution(jobExecutionIds.iterator().next()).getExecutionId());
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:18,
代码来源:TaskBatchExecutionListenerTests.java

示例3: testAutobuiltDataSourceNoJob

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testAutobuiltDataSourceNoJob() {
	this.applicationContext = SpringApplication.run(new Class[] {NoJobConfiguration.class,
			PropertyPlaceholderAutoConfiguration.class,
			EmbeddedDataSourceConfiguration.class,
			BatchAutoConfiguration.class,
			TaskBatchAutoConfiguration.class}, ARGS);

	TaskExplorer taskExplorer = this.applicationContext.getBean(TaskExplorer.class);

	Page<TaskExecution> page = taskExplorer.findTaskExecutionsByName("application", PageRequest.of(0, 1));

	Set<Long> jobExecutionIds = taskExplorer.getJobExecutionIdsByTaskExecutionId(page.iterator().next().getExecutionId());

	assertEquals(0, jobExecutionIds.size());
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:17,
代码来源:TaskBatchExecutionListenerTests.java

示例4: testMapBased

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testMapBased() {
	this.applicationContext = SpringApplication.run(new Class[] {JobConfiguration.class,
			PropertyPlaceholderAutoConfiguration.class, EmbeddedDataSourceConfiguration.class,
			BatchAutoConfiguration.class,
			TaskBatchAutoConfiguration.class}, ARGS);

	TaskExplorer taskExplorer = this.applicationContext.getBean(TaskExplorer.class);

	Page<TaskExecution> page = taskExplorer.findTaskExecutionsByName("application", PageRequest.of(0, 1));

	Set<Long> jobExecutionIds = taskExplorer.getJobExecutionIdsByTaskExecutionId(page.iterator().next().getExecutionId());

	assertEquals(1, jobExecutionIds.size());
	assertEquals(1, (long) taskExplorer.getTaskExecutionIdByJobExecutionId(jobExecutionIds.iterator().next()));
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:17,
代码来源:TaskBatchExecutionListenerTests.java

示例5: testMultipleJobs

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testMultipleJobs() {
	this.applicationContext = SpringApplication.run(new Class[] {EmbeddedDataSourceConfiguration.class, MultipleJobConfiguration.class,
			PropertyPlaceholderAutoConfiguration.class,
			BatchAutoConfiguration.class,
			TaskBatchAutoConfiguration.class}, ARGS);

	TaskExplorer taskExplorer = this.applicationContext.getBean(TaskExplorer.class);

	Page<TaskExecution> page = taskExplorer.findTaskExecutionsByName("application", PageRequest.of(0, 1));

	Set<Long> jobExecutionIds = taskExplorer.getJobExecutionIdsByTaskExecutionId(page.iterator().next().getExecutionId());

	assertEquals(2, jobExecutionIds.size());
	Iterator<Long> jobExecutionIdsIterator = jobExecutionIds.iterator();
	assertEquals(1, (long) taskExplorer.getTaskExecutionIdByJobExecutionId(jobExecutionIdsIterator.next()));
	assertEquals(1, (long) taskExplorer.getTaskExecutionIdByJobExecutionId(jobExecutionIdsIterator.next()));
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:19,
代码来源:TaskBatchExecutionListenerTests.java

示例6: TaskLifecycleListener

点赞 3

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
/**
 * @param taskRepository The repository to record executions in.
 */
public TaskLifecycleListener(TaskRepository taskRepository,
		TaskNameResolver taskNameResolver,
		ApplicationArguments applicationArguments, TaskExplorer taskExplorer,
		TaskProperties taskProperties) {
	Assert.notNull(taskRepository, "A taskRepository is required");
	Assert.notNull(taskNameResolver, "A taskNameResolver is required");
	Assert.notNull(taskExplorer, "A taskExplorer is required");
	Assert.notNull(taskProperties, "TaskProperties is required");

	this.taskRepository = taskRepository;
	this.taskNameResolver = taskNameResolver;
	this.applicationArguments = applicationArguments;
	this.taskExplorer = taskExplorer;
	this.taskProperties = taskProperties;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:19,
代码来源:TaskLifecycleListener.java

示例7: TaskLauncherTasklet

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
public TaskLauncherTasklet(
		TaskOperations taskOperations, TaskExplorer taskExplorer,
		ComposedTaskProperties composedTaskProperties, String taskName) {
	Assert.hasText(taskName, "taskName must not be empty nor null.");
	Assert.notNull(taskOperations, "taskOperations must not be null.");
	Assert.notNull(taskExplorer, "taskExplorer must not be null.");
	Assert.notNull(composedTaskProperties,
			"composedTaskProperties must not be null");

	this.taskName = taskName;
	this.taskOperations = taskOperations;
	this.taskExplorer = taskExplorer;
	this.composedTaskProperties = composedTaskProperties;
}
 

开发者ID:spring-cloud-task-app-starters,
项目名称:composed-task-runner,
代码行数:15,
代码来源:TaskLauncherTasklet.java

示例8: setup

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Before
public void setup() {
	this.taskExplorer = mock(TaskExplorer.class);
	this.properties = new ComposedTaskProperties();
	this.stepExecution = getStepExecution();
	this.taskListener =
			new ComposedTaskStepExecutionListener(this.taskExplorer);

}
 

开发者ID:spring-cloud-task-app-starters,
项目名称:composed-task-runner,
代码行数:10,
代码来源:ComposedTaskStepExecutionListenerTests.java

示例9: TaskExecutionController

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
/**
 * Creates a {@code TaskExecutionController} that retrieves Task Execution information
 * from a the {@link TaskExplorer}
 *
 * @param explorer the explorer this controller will use for retrieving task execution
 * information.
 * @param taskService used to launch tasks
 * @param taskDefinitionRepository the task definition repository
 */
public TaskExecutionController(TaskExplorer explorer, TaskService taskService,
		TaskDefinitionRepository taskDefinitionRepository) {
	Assert.notNull(explorer, "explorer must not be null");
	Assert.notNull(taskService, "taskService must not be null");
	Assert.notNull(taskDefinitionRepository, "taskDefinitionRepository must not be null");
	this.taskService = taskService;
	this.explorer = explorer;
	this.taskDefinitionRepository = taskDefinitionRepository;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:19,
代码来源:TaskExecutionController.java

示例10: DefaultTaskService

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
/**
 * Initializes the {@link DefaultTaskService}.
 *
 * @param dataSourceProperties the data source properties.
 * @param taskDefinitionRepository the {@link TaskDefinitionRepository} this service will
 * use for task CRUD operations.
 * @param taskExecutionRepository the repository this service will use for deployment IDs.
 * @param taskExplorer the explorer this service will use to lookup task executions
 * @param registry URI registry this service will use to look up app URIs.
 * @param resourceLoader the {@link ResourceLoader} that will resolve URIs to
 * {@link Resource}s.
 * @param taskLauncher the launcher this service will use to launch task apps.
 * @param metaDataResolver the metadata resolver
 * @param taskConfigurationProperties the properties used to define the behavior of tasks
 * @param deploymentIdRepository the repository that maps deployment keys to IDs
 * @param dataflowServerUri the data flow server URI
 */
public DefaultTaskService(DataSourceProperties dataSourceProperties,
		TaskDefinitionRepository taskDefinitionRepository, TaskExplorer taskExplorer,
		TaskRepository taskExecutionRepository, AppRegistryCommon registry, ResourceLoader resourceLoader,
		TaskLauncher taskLauncher, ApplicationConfigurationMetadataResolver metaDataResolver,
		TaskConfigurationProperties taskConfigurationProperties, DeploymentIdRepository deploymentIdRepository,
		String dataflowServerUri) {
	Assert.notNull(dataSourceProperties, "DataSourceProperties must not be null");
	Assert.notNull(taskDefinitionRepository, "TaskDefinitionRepository must not be null");
	Assert.notNull(taskExecutionRepository, "TaskExecutionRepository must not be null");
	Assert.notNull(taskExplorer, "TaskExplorer must not be null");
	Assert.notNull(registry, "UriRegistry must not be null");
	Assert.notNull(resourceLoader, "ResourceLoader must not be null");
	Assert.notNull(taskLauncher, "TaskLauncher must not be null");
	Assert.notNull(metaDataResolver, "metaDataResolver must not be null");
	Assert.notNull(taskConfigurationProperties, "taskConfigurationProperties must not be null");
	Assert.notNull(deploymentIdRepository, "deploymentIdRepository must not be null");
	this.dataSourceProperties = dataSourceProperties;
	this.taskDefinitionRepository = taskDefinitionRepository;
	this.taskExecutionRepository = taskExecutionRepository;
	this.taskExplorer = taskExplorer;
	this.registry = registry;
	this.taskLauncher = taskLauncher;
	this.resourceLoader = resourceLoader;
	this.whitelistProperties = new WhitelistProperties(metaDataResolver);
	this.taskConfigurationProperties = taskConfigurationProperties;
	this.deploymentIdRepository = deploymentIdRepository;
	this.dataflowServerUri = dataflowServerUri;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:46,
代码来源:DefaultTaskService.java

示例11: DefaultTaskJobService

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
public DefaultTaskJobService(JobService jobService, TaskExplorer taskExplorer,
		TaskDefinitionRepository taskDefinitionRepository, TaskService taskService) {
	Assert.notNull(jobService, "jobService must not be null");
	Assert.notNull(taskExplorer, "taskExplorer must not be null");
	Assert.notNull(taskDefinitionRepository, "taskDefinitionRepository must not be null");
	Assert.notNull(taskService, "taskService must not be null");
	this.jobService = jobService;
	this.taskExplorer = taskExplorer;
	this.taskDefinitionRepository = taskDefinitionRepository;
	this.taskService = taskService;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:12,
代码来源:DefaultTaskJobService.java

示例12: taskService

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
@ConditionalOnBean(TaskDefinitionRepository.class)
public TaskService taskService(TaskDefinitionRepository repository, TaskExplorer taskExplorer,
		TaskRepository taskExecutionRepository, AppRegistryCommon registry, DelegatingResourceLoader resourceLoader,
		TaskLauncher taskLauncher, ApplicationConfigurationMetadataResolver metadataResolver,
		TaskConfigurationProperties taskConfigurationProperties, DeploymentIdRepository deploymentIdRepository) {
	return new DefaultTaskService(dataSourceProperties, repository, taskExplorer, taskExecutionRepository, registry,
			resourceLoader, taskLauncher, metadataResolver, taskConfigurationProperties, deploymentIdRepository,
			this.dataflowServerUri);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:11,
代码来源:TaskConfiguration.java

示例13: taskExecutionController

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExecutionController taskExecutionController(TaskExplorer explorer,
		ApplicationConfigurationMetadataResolver metadataResolver, DeploymentIdRepository deploymentIdRepository,
		AppRegistryCommon appRegistry, DelegatingResourceLoader delegatingResourceLoader) {
	return new TaskExecutionController(explorer,
			taskService(metadataResolver, taskRepository(), deploymentIdRepository, appRegistry, delegatingResourceLoader),
			taskDefinitionRepository());
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:9,
代码来源:TestDependencies.java

示例14: defaultTaskService

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public DefaultTaskService defaultTaskService(TaskDefinitionRepository taskDefinitionRepository, TaskExplorer taskExplorer,
		TaskRepository taskExecutionRepository, AppRegistry appRegistry,
		ResourceLoader resourceLoader, TaskLauncher taskLauncher,
		ApplicationConfigurationMetadataResolver metadataResolver) {
	return new DefaultTaskService(dataSourceProperties, taskDefinitionRepository, taskExplorer,
			taskExecutionRepository, appRegistry, resourceLoader, taskLauncher, metadataResolver,
			new TaskConfigurationProperties(), new InMemoryDeploymentIdRepository(), null);

}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:11,
代码来源:TaskServiceDependencies.java

示例15: taskService

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskService taskService(TaskDefinitionRepository repository, TaskExplorer explorer, AppRegistry registry,
		ResourceLoader resourceLoader, TaskLauncher taskLauncher,
		ApplicationConfigurationMetadataResolver metadataResolver, DeploymentIdRepository deploymentIdRepository) {
	return new DefaultTaskService(new DataSourceProperties(), repository, explorer, taskRepository(), registry,
			resourceLoader, taskLauncher, metadataResolver, new TaskConfigurationProperties(),
			deploymentIdRepository, null);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:9,
代码来源:JobDependencies.java

示例16: taskBatchExecutionListener

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskBatchExecutionListenerFactoryBean taskBatchExecutionListener(TaskExplorer taskExplorer) {
	TaskConfigurer taskConfigurer = null;
	if(!context.getBeansOfType(TaskConfigurer.class).isEmpty()) {
		taskConfigurer = context.getBean(TaskConfigurer.class);
	}
	if(taskConfigurer != null && taskConfigurer.getTaskDataSource() != null) {
		return new TaskBatchExecutionListenerFactoryBean(
				taskConfigurer.getTaskDataSource(),
				taskExplorer);
	}
	else {
		return new TaskBatchExecutionListenerFactoryBean(null, taskExplorer);
	}
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:16,
代码来源:TaskBatchAutoConfiguration.java

示例17: testRepositoryInitialized

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testRepositoryInitialized() throws Exception {
	this.context = new AnnotationConfigApplicationContext(EmbeddedDataSourceConfiguration.class, SimpleTaskConfiguration.class,
			PropertyPlaceholderAutoConfiguration.class);

	TaskExplorer taskExplorer = this.context.getBean(TaskExplorer.class);

	assertThat(taskExplorer.getTaskExecutionCount(), is(equalTo(1l)));
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:10,
代码来源:SimpleTaskConfigurationTests.java

示例18: testTaskCreateWithArgs

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testTaskCreateWithArgs() {
	context.register(ArgsConfiguration.class);
	context.refresh();
	this.taskExplorer = context.getBean(TaskExplorer.class);
	verifyTaskExecution(2, false);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:8,
代码来源:TaskLifecycleListenerTests.java

示例19: testTaskUpdate

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testTaskUpdate() {
	context.refresh();
	this.taskExplorer = context.getBean(TaskExplorer.class);

	context.publishEvent(new ApplicationReadyEvent(new SpringApplication(), new String[0], context));

	verifyTaskExecution(0, true);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:10,
代码来源:TaskLifecycleListenerTests.java

示例20: testTaskFailedUpdate

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testTaskFailedUpdate() {
	context.refresh();
	RuntimeException exception = new RuntimeException("This was expected");
	SpringApplication application = new SpringApplication();
	this.taskExplorer = context.getBean(TaskExplorer.class);
	context.publishEvent(new ApplicationFailedEvent(application, new String[0], context, exception));
	context.publishEvent(new ApplicationReadyEvent(application, new String[0], context));

	verifyTaskExecution(0, true, 1, exception, null);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:12,
代码来源:TaskLifecycleListenerTests.java

示例21: testTaskFailedWithExitCodeEvent

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testTaskFailedWithExitCodeEvent() {
	final int exitCode = 10;
	context.refresh();
	RuntimeException exception = new RuntimeException("This was expected");
	SpringApplication application = new SpringApplication();
	this.taskExplorer = context.getBean(TaskExplorer.class);
	context.publishEvent(new ExitCodeEvent(context, exitCode));
	context.publishEvent(new ApplicationFailedEvent(application, new String[0], context, exception));
	context.publishEvent(new ApplicationReadyEvent(application, new String[0], context));

	verifyTaskExecution(0, true, exitCode, exception, null);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:14,
代码来源:TaskLifecycleListenerTests.java

示例22: testExternalExecutionId

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testExternalExecutionId() {
	ConfigurableEnvironment environment = new StandardEnvironment();
	MutablePropertySources propertySources = environment.getPropertySources();
	Map myMap = new HashMap();
	myMap.put("spring.cloud.task.external-execution-id", "myid");
	propertySources.addFirst(new MapPropertySource("EnvrionmentTestPropsource", myMap));
	context.setEnvironment(environment);
	context.refresh();
	this.taskExplorer = context.getBean(TaskExplorer.class);

	verifyTaskExecution(0, false, 0, null, "myid");
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:14,
代码来源:TaskLifecycleListenerTests.java

示例23: testParentExecutionId

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testParentExecutionId() {
	ConfigurableEnvironment environment = new StandardEnvironment();
	MutablePropertySources propertySources = environment.getPropertySources();
	Map myMap = new HashMap();
	myMap.put("spring.cloud.task.parentExecutionId", 789);
	propertySources.addFirst(new MapPropertySource("EnvrionmentTestPropsource", myMap));
	context.setEnvironment(environment);
	context.refresh();
	this.taskExplorer = context.getBean(TaskExplorer.class);

	verifyTaskExecution(0, false, 0, null, null, 789L);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:14,
代码来源:TaskLifecycleListenerTests.java

示例24: ComposedTaskStepExecutionListener

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
public ComposedTaskStepExecutionListener(TaskExplorer taskExplorer) {
	Assert.notNull(taskExplorer, "taskExplorer must not be null.");
	this.taskExplorer = taskExplorer;
}
 

开发者ID:spring-cloud-task-app-starters,
项目名称:composed-task-runner,
代码行数:5,
代码来源:ComposedTaskStepExecutionListener.java

示例25: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer() {
	return mock(TaskExplorer.class);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dashboard,
代码行数:5,
代码来源:TestDependencies.java

示例26: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer() {
	TaskExecutionDaoFactoryBean factoryBean = new TaskExecutionDaoFactoryBean(this.dataSource);
	return new SimpleTaskExplorer(factoryBean);
}
 

开发者ID:mminella,
项目名称:TaskMadness,
代码行数:6,
代码来源:TaskConfiguration.java

示例27: getObjectType

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Override
public Class<?> getObjectType() {
	return TaskExplorer.class;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:5,
代码来源:TaskExplorerFactoryBean.java

示例28: taskJobExecutionRepository

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
@ConditionalOnBean(TaskDefinitionRepository.class)
public TaskJobService taskJobExecutionRepository(JobService service, TaskExplorer taskExplorer,
		TaskDefinitionRepository taskDefinitionRepository, TaskService taskService) {
	return new DefaultTaskJobService(service, taskExplorer, taskDefinitionRepository, taskService);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:7,
代码来源:TaskConfiguration.java

示例29: taskExecutionController

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
@ConditionalOnBean(TaskDefinitionRepository.class)
public TaskExecutionController taskExecutionController(TaskExplorer explorer, TaskService taskService,
		TaskDefinitionRepository taskDefinitionRepository) {
	return new TaskExecutionController(explorer, taskService, taskDefinitionRepository);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:7,
代码来源:DataFlowControllerAutoConfiguration.java

示例30: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer(DataSource dataSource) {
	return new SimpleTaskExplorer(new TaskExecutionDaoFactoryBean(dataSource));
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:5,
代码来源:TaskDependencies.java

示例31: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer(TaskExecutionDaoFactoryBean daoFactoryBean) {
	return new SimpleTaskExplorer(daoFactoryBean);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:5,
代码来源:TaskServiceDependencies.java

示例32: taskExecutionController

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExecutionController taskExecutionController(TaskExplorer explorer, TaskService taskService,
		TaskDefinitionRepository taskDefinitionRepository) {
	return new TaskExecutionController(explorer, taskService, taskDefinitionRepository);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:6,
代码来源:JobDependencies.java

示例33: taskJobExecutionRepository

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskJobService taskJobExecutionRepository(JobService jobService, TaskExplorer taskExplorer,
		TaskDefinitionRepository taskDefinitionRepository, TaskService taskService) {
	return new DefaultTaskJobService(jobService, taskExplorer, taskDefinitionRepository, taskService);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-dataflow,
代码行数:6,
代码来源:JobDependencies.java

示例34: getTaskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Override
public TaskExplorer getTaskExplorer() {
	return this.taskExplorer;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:5,
代码来源:DefaultTaskConfigurer.java

示例35: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer() {
	return this.taskExplorer;
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:5,
代码来源:SimpleTaskConfiguration.java

示例36: testTaskCreate

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Test
public void testTaskCreate() {
	context.refresh();
	this.taskExplorer = context.getBean(TaskExplorer.class);
	verifyTaskExecution(0, false);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:7,
代码来源:TaskLifecycleListenerTests.java

示例37: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer() throws Exception {
	return new SimpleTaskExplorer(this.taskExecutionDaoFactoryBean);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:5,
代码来源:TestConfiguration.java

示例38: taskExplorer

点赞 2

import org.springframework.cloud.task.repository.TaskExplorer; //导入依赖的package包/类
@Bean
public TaskExplorer taskExplorer() throws Exception {
	return new SimpleTaskExplorer(this.factoryBean);
}
 

开发者ID:spring-cloud,
项目名称:spring-cloud-task,
代码行数:5,
代码来源:TestDefaultConfiguration.java


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)