GH-1981 Fix delayed subscription for reactive consumer

Resolves #1981
2020-09-22 21:42:00 +02:00
parent 9a906e7369
commit ac98fb1206
1 changed files with 3 additions and 1 deletions
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
@@ -425,7 +425,9 @@ public class FunctionConfiguration {
 							}
 						});
 					}
-					flux.subscribe();
+					if (!function.isConsumer()) {
+						flux.subscribe();
+					}
 				});
 			}
 			else {