Package org.activiti.cloud.common.messaging.config

Class AbstractFunctionalBindingConfiguration

java.lang.Object

org.activiti.cloud.common.messaging.config.AbstractFunctionalBindingConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

ConnectorConfiguration, FunctionBindingConfiguration, InputBindingConfiguration, OutputBindingConfiguration

public abstract class AbstractFunctionalBindingConfiguration
extends Object
implements org.springframework.context.ApplicationContextAware

Constructor Summary

Constructors

Constructor	Description
AbstractFunctionalBindingConfiguration()

Method Summary

Modifier and Type	Method	Description
protected Type	discoverFunctionType(Object bean, String beanName)
protected org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry.FunctionInvocationWrapper	functionFromDefinition(String definition)
protected Class<?>	getGatewayInterface(boolean hasOutput)
static String	getInBinding(String bindingName)
static String	getInBinding(String bindingName, int arity)
protected org.springframework.messaging.converter.CompositeMessageConverter	getMessageConverter()
protected org.springframework.cloud.stream.binding.MessageConverterConfigurer	getMessageConverterConfigurer()
static String	getOutBinding(String bindingName)
static String	getOutBinding(String bindingName, int arity)
protected org.springframework.cloud.stream.function.StreamBridge	getStreamBridge()
protected void	registerFunctionRegistration(String functionName, org.springframework.cloud.function.context.FunctionRegistration functionRegistration)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFunctionalBindingConfiguration

public AbstractFunctionalBindingConfiguration()

Method Detail

setApplicationContext

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

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getStreamBridge

protected org.springframework.cloud.stream.function.StreamBridge getStreamBridge()

getOutBinding

public static String getOutBinding(String bindingName)

getOutBinding

public static String getOutBinding(String bindingName,
                                   int arity)

getInBinding

public static String getInBinding(String bindingName)

getInBinding

public static String getInBinding(String bindingName,
                                  int arity)

getGatewayInterface

protected Class<?> getGatewayInterface(boolean hasOutput)

functionFromDefinition

protected org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry.FunctionInvocationWrapper functionFromDefinition(String definition)

discoverFunctionType

protected Type discoverFunctionType(Object bean,
                                    String beanName)

registerFunctionRegistration

protected void registerFunctionRegistration(String functionName,
                                            org.springframework.cloud.function.context.FunctionRegistration functionRegistration)

getMessageConverter

protected org.springframework.messaging.converter.CompositeMessageConverter getMessageConverter()

getMessageConverterConfigurer

protected org.springframework.cloud.stream.binding.MessageConverterConfigurer getMessageConverterConfigurer()