Class BindableFunctionProxyFactory

java.lang.Object

org.springframework.cloud.stream.binding.AbstractBindableProxyFactory

org.springframework.cloud.stream.binding.BindableProxyFactory

org.springframework.cloud.stream.function.BindableFunctionProxyFactory

All Implemented Interfaces:

Bindable

public class BindableFunctionProxyFactory
extends BindableProxyFactory

FactoryBean for creating inputs/outputs destinations to be bound to function arguments. It is an extension to BindableProxyFactory which operates on Bindable interfaces (e.g., Source, Processor, Sink) which internally define inputs and output channels. Unlike BindableProxyFactory, this class operates based on the count of provided inputs and outputs deriving the binding (channel) names based on convention - `<function-definition>. + <in/out> + .<index>`
For example, `myFunction.in.0` - is the binding for the first input argument of the function with the name `myFunction`.

Since:

3.0

Author:

Oleg Zhurakousky, Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
static final String	OBJECT_TYPE_ATTRIBUTE

Fields inherited from class BindableProxyFactory

beanFactory

Fields inherited from class AbstractBindableProxyFactory

bindingTargetFactories, inputHolders, outputHolders, type

Constructor Summary

Constructors

Constructor	Description
BindableFunctionProxyFactory(String functionDefinition, int inputCount, int outputCount, StreamFunctionProperties functionProperties)
BindableFunctionProxyFactory(String functionDefinition, int inputCount, int outputCount, StreamFunctionProperties functionProperties, boolean functionExist)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
static Map<String,String>	getChannelNameToFunctions()
String	getFunctionDefinition()
protected String	getInputName(int index)
Class<?>	getObjectType()
protected String	getOutputName(int index)
boolean	isFunctionExist()
protected boolean	isMultiple()
boolean	isSingleton()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
String	toString()

Methods inherited from class BindableProxyFactory

getObject, invoke, replaceInputChannel, replaceOutputChannel, setBeanFactory

Methods inherited from class AbstractBindableProxyFactory

createAndBindInputs, createAndBindOutputs, getBindingTargetFactory, getInputs, getOutputs, populateBindingTargetFactories, unbindInputs, unbindOutputs

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

OBJECT_TYPE_ATTRIBUTE

static final String OBJECT_TYPE_ATTRIBUTE

See Also:

• Constant Field Values

Constructor Details

BindableFunctionProxyFactory

public BindableFunctionProxyFactory(String functionDefinition,
 int inputCount,
 int outputCount,
 StreamFunctionProperties functionProperties)

BindableFunctionProxyFactory

public BindableFunctionProxyFactory(String functionDefinition,
 int inputCount,
 int outputCount,
 StreamFunctionProperties functionProperties,
 boolean functionExist)

Method Details

toString

public String toString()

Overrides:

toString in class Object

afterPropertiesSet

public void afterPropertiesSet()

Overrides:

afterPropertiesSet in class BindableProxyFactory

getObjectType

public Class<?> getObjectType()

Overrides:

getObjectType in class BindableProxyFactory

isSingleton

public boolean isSingleton()

Overrides:

isSingleton in class BindableProxyFactory

getFunctionDefinition

public String getFunctionDefinition()

getInputName

protected String getInputName(int index)

getOutputName

protected String getOutputName(int index)

isMultiple

protected boolean isMultiple()

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Throws:

org.springframework.beans.BeansException

isFunctionExist

public boolean isFunctionExist()

getChannelNameToFunctions

public static Map<String,String> getChannelNameToFunctions()