From 446633126690ad669087326b783690ca2da8ff96 Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Wed, 6 Apr 2016 15:15:16 +0530 Subject: [PATCH] Set namespace when using AggregateApplication.run() - When the apps are aggregated by calling AggregateApplication.run() the namespace for the apps need to be set before creating shared channel registry --- .../cloud/stream/aggregate/AggregateApplication.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/aggregate/AggregateApplication.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/aggregate/AggregateApplication.java index f2868b2d7..faed0c19e 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/aggregate/AggregateApplication.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/aggregate/AggregateApplication.java @@ -119,8 +119,9 @@ public class AggregateApplication { protected static void prepareSharedChannelRegistry(SharedChannelRegistry sharedChannelRegistry, Class[] apps) { LinkedHashMap, String> appsToRegister = new LinkedHashMap<>(); - for (Class app : apps) { - appsToRegister.put(app, null); + for (int i = apps.length - 1; i >= 0; i--) { + String appClassName = apps[i].getName(); + appsToRegister.put(apps[i], getNamespace(appClassName, i)); } prepareSharedChannelRegistry(sharedChannelRegistry, appsToRegister); }