diff --git a/spring-cloud-stream-module-launcher/src/main/java/org/springframework/boot/loader/ModuleJarLauncher.java b/spring-cloud-stream-module-launcher/src/main/java/org/springframework/boot/loader/ModuleJarLauncher.java index cba91d17e..55b3cf5ea 100644 --- a/spring-cloud-stream-module-launcher/src/main/java/org/springframework/boot/loader/ModuleJarLauncher.java +++ b/spring-cloud-stream-module-launcher/src/main/java/org/springframework/boot/loader/ModuleJarLauncher.java @@ -51,6 +51,7 @@ public class ModuleJarLauncher extends ExecutableArchiveLauncher { } @Override + // TODO: this method is protected in Spring Boot but we need it to be public here public void launch(String[] args) { super.launch(args); } 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 dad652e04..e4a6a7152 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 @@ -70,7 +70,7 @@ public class ModuleLauncher { */ public void launch(String[] modules, String[] args) { for (String module : modules) { - List moduleArgs = new ArrayList<>(); + List moduleArgs = new ArrayList<>(); for (String arg : args) { if (arg.startsWith("--" + module + ".")) { moduleArgs.add("--" + arg.substring(module.length() + 3)); @@ -102,7 +102,7 @@ public class ModuleLauncher { String extension = StringUtils.hasLength(matcher.group(4)) ? matcher.group(4) : DEFAULT_EXTENSION; String classifier = StringUtils.hasLength(matcher.group(6)) ? matcher.group(6) : DEFAULT_CLASSIFIER; String version = matcher.group(7); - return moduleResolver.resolve(groupId, artifactId, extension, classifier, version); + return this.moduleResolver.resolve(groupId, artifactId, extension, classifier, version); } }