SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

create local repo dir if it does not exist

Browse Source
This commit is contained in:
Mark Fisher
2015-07-31 14:38:01 -04:00
committed by Marius Bogoevici
parent 50ff27b7c8
commit 5b5b31d178
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/launcher/ModuleLauncher.java
View File

@@ -31,7 +31,6 @@ import org.springframework.cloud.stream.module.resolver.AetherModuleResolver;
import org.springframework.cloud.stream.module.resolver.ModuleResolver;
import org.springframework.core.io.Resource;
import org.springframework.util.Assert;
import org.springframework.util.FileSystemUtils;
import org.springframework.util.StringUtils;
/**

6
spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/resolver/AetherModuleResolver.java
View File

@@ -49,6 +49,7 @@ import org.springframework.util.CollectionUtils;
* necessary.
*
* @author David Turanski
* @author Mark Fisher
*/
public class AetherModuleResolver implements ModuleResolver {
@@ -67,7 +68,10 @@ public class AetherModuleResolver implements ModuleResolver {
* may be null or empty if the local repository is off line.
*/
public AetherModuleResolver(File localRepository, Map<String, String> remoteRepositories) {
Assert.isTrue(localRepository.exists(), "File " + localRepository + " does not exist.");
if (!localRepository.exists()) {
Assert.isTrue(localRepository.mkdirs(),
"Unable to create directory for local repository: " + localRepository);
}
this.localRepository = localRepository;
this.remoteRepositories = new LinkedList<>();
if (!CollectionUtils.isEmpty(remoteRepositories)) {