Class ConsumerEndpointFactoryBean
java.lang.Object
org.springframework.integration.config.ConsumerEndpointFactoryBean
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<AbstractEndpoint>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class ConsumerEndpointFactoryBean
extends Object
implements org.springframework.beans.factory.FactoryBean<AbstractEndpoint>, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean
The
FactoryBean implementation for AbstractEndpoint population.
Controls all the necessary properties and lifecycle.
According the provided MessageChannel implementation populates
a PollingConsumer for the PollableChannel,
an EventDrivenConsumer for the SubscribableChannel
and ReactiveStreamsConsumer for all other channel implementations.-
Field Summary
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoiddestroy()org.springframework.messaging.MessageHandlerClass<?>intgetPhase()booleanbooleanvoidsetAdviceChain(List<org.aopalliance.aop.Advice> adviceChain) voidsetAutoStartup(Boolean autoStartup) voidsetBeanClassLoader(ClassLoader classLoader) voidsetBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) voidsetBeanName(String beanName) voidsetChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver) Specify theDestinationResolverstrategy to use.voidsetHandler(Object handler) voidsetInputChannel(org.springframework.messaging.MessageChannel inputChannel) voidsetInputChannelName(String inputChannelName) voidsetPhase(int phase) voidsetPollerMetadata(PollerMetadata pollerMetadata) voidsetReactiveCustomizer(Function<? super reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>, ? extends org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>> reactiveCustomizer) voidvoidsetTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) voidstart()voidstop()voidMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.beans.factory.FactoryBean
isSingleton
-
Constructor Details
-
ConsumerEndpointFactoryBean
public ConsumerEndpointFactoryBean()
-
-
Method Details
-
setHandler
-
getHandler
public org.springframework.messaging.MessageHandler getHandler() -
setInputChannel
public void setInputChannel(org.springframework.messaging.MessageChannel inputChannel) -
setInputChannelName
-
setPollerMetadata
-
setReactiveCustomizer
public void setReactiveCustomizer(@Nullable Function<? super reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>, ? extends org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>> reactiveCustomizer) -
setChannelResolver
public void setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver) Specify theDestinationResolverstrategy to use. The default is a BeanFactoryChannelResolver.- Parameters:
channelResolver- The channel resolver.- Since:
- 4.1.3
-
setBeanClassLoader
- Specified by:
setBeanClassLoaderin interfaceorg.springframework.beans.factory.BeanClassLoaderAware
-
setAutoStartup
-
setPhase
public void setPhase(int phase) -
setRole
-
setBeanName
- Specified by:
setBeanNamein interfaceorg.springframework.beans.factory.BeanNameAware
-
setBeanFactory
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) - Specified by:
setBeanFactoryin interfaceorg.springframework.beans.factory.BeanFactoryAware
-
setAdviceChain
-
setTaskScheduler
public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) -
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-
getObject
- Specified by:
getObjectin interfaceorg.springframework.beans.factory.FactoryBean<AbstractEndpoint>
-
getObjectType
- Specified by:
getObjectTypein interfaceorg.springframework.beans.factory.FactoryBean<AbstractEndpoint>
-
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
getPhase
public int getPhase()- Specified by:
getPhasein interfaceorg.springframework.context.Phased- Specified by:
getPhasein interfaceorg.springframework.context.SmartLifecycle
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
stop
- Specified by:
stopin interfaceorg.springframework.context.SmartLifecycle
-
destroy
public void destroy()- Specified by:
destroyin interfaceorg.springframework.beans.factory.DisposableBean
-