import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Test
@SuppressWarnings("unchecked")
public void testGetResourceExceptionHandler() {
	DelegatingResourceLoader resourceLoader = mock(DelegatingResourceLoader.class);
	AppDeploymentRequestFactory appDeploymentRequestFactory = new AppDeploymentRequestFactory(resourceLoader);
	when(resourceLoader.getResource(anyString())).thenThrow(Exception.class);
	SpringCloudDeployerApplicationManifest applicationSpec = mock(SpringCloudDeployerApplicationManifest.class);
	SpringCloudDeployerApplicationSpec springCloudDeployerApplicationSpec = mock(SpringCloudDeployerApplicationSpec.class);
	when(applicationSpec.getSpec()).thenReturn(springCloudDeployerApplicationSpec);
	String specResource = "http://test";
	when(springCloudDeployerApplicationSpec.getResource()).thenReturn(specResource);
	when(springCloudDeployerApplicationSpec.getApplicationProperties()).thenReturn(null);
	try {
		appDeploymentRequestFactory.createAppDeploymentRequest(applicationSpec, "release1", "1.0.0");
		fail("SkipperException is expected to be thrown.");
	}
	catch (SkipperException e) {
		assertThat(e.getMessage()).contains("Could not load Resource " + specResource + ".");
	}
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public DelegatingResourceLoader delegatingResourceLoader(MavenConfigurationProperties mavenProperties) {
	DockerResourceLoader dockerLoader = new DockerResourceLoader();
	MavenResourceLoader mavenResourceLoader = new MavenResourceLoader(mavenProperties);
	Map<String, ResourceLoader> loaders = new HashMap<>();
	loaders.put("docker", dockerLoader);
	loaders.put("maven", mavenResourceLoader);
	return new DelegatingResourceLoader(loaders);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean(DelegatingResourceLoader.class)
public DelegatingResourceLoader delegatingResourceLoader(MavenResourceLoader mavenResourceLoader) {
	Map<String, ResourceLoader> loaders = new HashMap<>();
	loaders.put("maven", mavenResourceLoader);
	return new DelegatingResourceLoader(loaders);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public ResourceLoader resourceLoader() {
	MavenProperties mavenProperties = new MavenProperties();
	mavenProperties.setRemoteRepositories(new HashMap<>(Collections.singletonMap("springRepo",
			new MavenProperties.RemoteRepository("https://repo.spring.io/libs-snapshot"))));

	Map<String, ResourceLoader> resourceLoaders = new HashMap<>();
	resourceLoaders.put("maven", new MavenResourceLoader(mavenProperties));
	resourceLoaders.put("file", new FileSystemResourceLoader());

	DelegatingResourceLoader delegatingResourceLoader = new DelegatingResourceLoader(resourceLoaders);
	return delegatingResourceLoader;
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Test
public void testLocalAutoConfigApplied() throws Exception {
	SpringApplication app = new SpringApplication(LocalTestDataFlowServer.class);
	context = app.run(new String[] { "--server.port=0" });

	// default on DataFlowControllerAutoConfiguration only adds maven,
	// LocalDataFlowServerAutoConfiguration also adds docker so test on those.
	LRUCleaningResourceLoader lruCleaningResourceLoader = context.getBean(LRUCleaningResourceLoader.class);
	DelegatingResourceLoader delegatingResourceLoader =
			(DelegatingResourceLoader)TestUtils.readField("delegate", lruCleaningResourceLoader);
	Map<String, ResourceLoader> loaders = TestUtils.readField("loaders", delegatingResourceLoader);
	assertThat(loaders.size(), is(2));
	assertThat(loaders.get("maven"), notNullValue());
	assertThat(loaders.get("docker"), notNullValue());
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的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);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public DelegatingResourceLoader resourceLoader(MavenProperties mavenProperties) {
	Map<String, ResourceLoader> resourceLoaders = new HashMap<>();
	resourceLoaders.put("maven", new MavenResourceLoader(mavenProperties));
	resourceLoaders.put("file", new FileSystemResourceLoader());

	DelegatingResourceLoader delegatingResourceLoader = new DelegatingResourceLoader(resourceLoaders);
	return delegatingResourceLoader;
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public TaskDefinitionController taskDefinitionController(TaskDefinitionRepository repository,
		DeploymentIdRepository deploymentIdRepository, ApplicationConfigurationMetadataResolver metadataResolver,
		AppRegistryCommon appRegistry, DelegatingResourceLoader delegatingResourceLoader) {
	return new TaskDefinitionController(repository, deploymentIdRepository, taskLauncher(), appRegistry,
			taskService(metadataResolver, taskRepository(), deploymentIdRepository, appRegistry, delegatingResourceLoader));
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的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());
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public TaskService taskService(ApplicationConfigurationMetadataResolver metadataResolver,
		TaskRepository taskExecutionRepository, DeploymentIdRepository deploymentIdRepository,
		AppRegistryCommon appRegistry, DelegatingResourceLoader delegatingResourceLoader) {
	return new DefaultTaskService(new DataSourceProperties(), taskDefinitionRepository(), taskExplorer(),
			taskExecutionRepository, appRegistry, delegatingResourceLoader, taskLauncher(), metadataResolver,
			new TaskConfigurationProperties(), deploymentIdRepository, null);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public DelegatingResourceLoader delegatingResourceLoader(MavenProperties mavenProperties) {
	DockerResourceLoader dockerLoader = new DockerResourceLoader();
	MavenResourceLoader mavenResourceLoader = new MavenResourceLoader(mavenProperties);
	Map<String, ResourceLoader> loaders = new HashMap<>();
	loaders.put("docker", dockerLoader);
	loaders.put("maven", mavenResourceLoader);
	return new DelegatingResourceLoader(loaders);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
@ConditionalOnMissingBean
public DelegatingResourceLoader delegatingResourceLoader(MavenResourceLoader mavenResourceLoader) {
	Map<String, ResourceLoader> loaders = new HashMap<>(1);
	loaders.put("maven", mavenResourceLoader);

	return new DelegatingResourceLoader(loaders);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Test
public void testTaskLauncher() {
	MavenResourceLoader mavenResourceLoader =
			context.getBean(MavenResourceLoader.class);
	assertNotNull(mavenResourceLoader);

	DelegatingResourceLoader delegatingResourceLoader =
			context.getBean(DelegatingResourceLoader.class);
	assertNotNull(delegatingResourceLoader);

	MavenProperties mavenProperties =
			context.getBean(MavenProperties.class);
	assertNotNull(mavenProperties);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public AppDeploymentRequestFactory appDeploymentRequestFactory(DelegatingResourceLoader delegatingResourceLoader) {
	return new AppDeploymentRequestFactory(delegatingResourceLoader);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public AppRegistry appRegistry(UriRegistry uriRegistry, DelegatingResourceLoader resourceLoader,
		EavRegistryRepository eavRegistryRepository) {
	return new AppRegistry(uriRegistry, resourceLoader, eavRegistryRepository);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public AppRegistryService appRegistryService(AppRegistrationRepository appRegistrationRepository,
		DelegatingResourceLoader resourceLoader, MavenProperties mavenProperties) {
	return new DefaultAppRegistryService(appRegistrationRepository, resourceLoader, mavenProperties);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public AppRegistry appRegistry(UriRegistry uriRegistry, DelegatingResourceLoader resourceLoader,
		MavenProperties mavenProperties) {
	return new AppRegistry(uriRegistry, resourceLoader, mavenProperties);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
@ConditionalOnSkipperDisabled
public AppRegistry appRegistry(UriRegistry uriRegistry, DelegatingResourceLoader resourceLoader) {
	return new AppRegistry(uriRegistry, resourceLoader);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
@ConditionalOnSkipperEnabled
public AppRegistryService appRegistryService(AppRegistrationRepository appRegistrationRepository,
		DelegatingResourceLoader resourceLoader, MavenProperties mavenProperties) {
	return new DefaultAppRegistryService(appRegistrationRepository, resourceLoader, mavenProperties);
}
 

import org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader; //导入依赖的package包/类
@Bean
public DelegatingResourceLoader delegatingResourceLoader(MavenResourceLoader mavenResourceLoader) {
	HashMap<String, ResourceLoader> map = new HashMap<>();
	map.put("maven", mavenResourceLoader);
	return new DelegatingResourceLoader(map);
}