From b53f2ccbea13dec78978c6fc405fe35c41efe5aa Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 3 Dec 2020 15:59:59 +0100 Subject: [PATCH] GH-2059 Fixed method name in assertion call Resolves #2059 --- .../springframework/cloud/stream/binder/DefaultBinding.java | 4 +++- .../cloud/stream/function/FunctionConfiguration.java | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java index e47bcca24..56482b1bc 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java @@ -83,10 +83,12 @@ public class DefaultBinding implements Binding { this.restartable = true; } + @Override public String getName() { return this.name; } + @Override public String getBindingName() { String resolvedName = (this.target instanceof IntegrationObjectSupport) ? ((IntegrationObjectSupport) this.target).getComponentName() : getName(); @@ -110,6 +112,7 @@ public class DefaultBinding implements Binding { return state; } + @Override public boolean isRunning() { return this.lifecycle != null && this.lifecycle.isRunning(); } @@ -118,7 +121,6 @@ public class DefaultBinding implements Binding { return this.lifecycle instanceof Pausable; } - @Override public boolean isPaused() { return this.paused; } diff --git 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 index df913d4ad..25b66409b 100644 --- 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 @@ -593,7 +593,7 @@ public class FunctionConfiguration { } int outputCount = FunctionTypeUtils.getOutputCount(functionType); for (int i = 0; i < outputCount; i++) { - Assert.isTrue(FunctionTypeUtils.isReactive(FunctionTypeUtils.getInputType(functionType, i)), + Assert.isTrue(FunctionTypeUtils.isReactive(FunctionTypeUtils.getOutputType(functionType, i)), "Function '" + functionProperties.getDefinition() + "' has the following signature: [" + functionType + "]. Non-reactive functions with multiple " + "inputs/outputs are not supported in the context of Spring Cloud Stream.");