@@ -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;
|
||||
}
|
||||
|
||||
@@ -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.");
|
||||
|
||||
Reference in New Issue
Block a user