From 5de1ec50d9575956b822942d1371b827a2410a72 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Fri, 31 Jul 2015 20:57:31 -0400 Subject: [PATCH] enable configuration of remote repo --- .../stream/module/launcher/ModuleLauncher.java | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/launcher/ModuleLauncher.java b/spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/launcher/ModuleLauncher.java index 6b0afd6bf..a55984fcf 100644 --- a/spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/launcher/ModuleLauncher.java +++ b/spring-cloud-stream-module-launcher/src/main/java/org/springframework/cloud/stream/module/launcher/ModuleLauncher.java @@ -52,6 +52,8 @@ public class ModuleLauncher { private static final String DEFAULT_LOCAL_REPO = System.getProperty("user.home") + File.separator + ".m2" + File.separator + "repository"; + private static final String DEFAULT_REMOTE_REPO = "http://repo.spring.io/spring-cloud-stream-modules"; + private static final String DEFAULT_EXTENSION = "jar"; private static final String DEFAULT_CLASSIFIER = "exec"; @@ -63,7 +65,7 @@ public class ModuleLauncher { public ModuleLauncher() { this(determineLocalRepositoryLocation(), - Collections.singletonMap("spring-cloud-stream-modules", "http://repo.spring.io/spring-cloud-stream-modules")); + Collections.singletonMap("spring-cloud-stream-modules", determineRemoteRepositoryLocation())); } public ModuleLauncher(String localRepository, Map remoteRepositories) { @@ -118,6 +120,17 @@ public class ModuleLauncher { return localRepository; } + private static String determineRemoteRepositoryLocation() { + String remoteRepository = System.getProperty("remote.repository"); + if (remoteRepository == null) { + remoteRepository = System.getenv("REMOTE_REPOSITORY"); + } + if (remoteRepository == null) { + remoteRepository = DEFAULT_REMOTE_REPO; + } + return remoteRepository; + } + public static void main(String[] args) throws Exception { String modules = System.getProperty("modules"); if (modules == null) {