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<Class<?>, 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);
 	}