Class BindableProxyFactory

java.lang.Object

org.springframework.cloud.stream.binding.AbstractBindableProxyFactory

org.springframework.cloud.stream.binding.BindableProxyFactory

All Implemented Interfaces:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.FactoryBean<Object>, org.springframework.beans.factory.InitializingBean, Bindable

Direct Known Subclasses:

BindableFunctionProxyFactory

public class BindableProxyFactory
extends AbstractBindableProxyFactory
implements org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.FactoryBean<Object>, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanFactoryAware

FactoryBean for instantiating the functions.

Author:

Marius Bogoevici, David Syer, Ilayaperumal Gopinathan, Oleg Zhurakousky, Soby Chacko, Omer Celik

Field Summary

Fields

Modifier and Type	Field	Description
protected org.springframework.beans.factory.BeanFactory	beanFactory

Fields inherited from class AbstractBindableProxyFactory

bindingTargetFactories, inputHolders, outputHolders, type

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
BindableProxyFactory(Class<?> type)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
Object	getObject()	Double-Checked Locking Optimization was used to avoid unnecessary locking overhead.
Class<?>	getObjectType()
Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)
boolean	isSingleton()
void	replaceInputChannel(String originalChannelName, String newChannelName, org.springframework.messaging.SubscribableChannel messageChannel)
void	replaceOutputChannel(String originalChannelName, String newChannelName, org.springframework.messaging.MessageChannel messageChannel)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

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, toString, wait, wait, wait

Field Details

beanFactory

protected org.springframework.beans.factory.BeanFactory beanFactory

Constructor Details

BindableProxyFactory

public BindableProxyFactory(Class<?> type)

Method Details

invoke

public Object invoke(org.aopalliance.intercept.MethodInvocation invocation)

Specified by:

invoke in interface org.aopalliance.intercept.MethodInterceptor

replaceInputChannel

public void replaceInputChannel(String originalChannelName,
 String newChannelName,
 org.springframework.messaging.SubscribableChannel messageChannel)

replaceOutputChannel

public void replaceOutputChannel(String originalChannelName,
 String newChannelName,
 org.springframework.messaging.MessageChannel messageChannel)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

getObject

public Object getObject()

Double-Checked Locking Optimization was used to avoid unnecessary locking overhead.

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<Object>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<Object>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<Object>

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException