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<T> implements Binding<T> {
 		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<T> implements Binding<T> {
 		return state;
 	}
 
+	@Override
 	public boolean isRunning() {
 		return this.lifecycle != null && this.lifecycle.isRunning();
 	}
@@ -118,7 +121,6 @@ public class DefaultBinding<T> implements Binding<T> {
 		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.");