Package org.springframework.integration.config

Class ConsumerEndpointFactoryBean

java.lang.Object

org.springframework.integration.config.ConsumerEndpointFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<AbstractEndpoint>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class ConsumerEndpointFactoryBean
extends Object
implements FactoryBean<AbstractEndpoint>, BeanFactoryAware, BeanNameAware, BeanClassLoaderAware, InitializingBean, SmartLifecycle, 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.

Author:

Mark Fisher, Oleg Zhurakousky, Josh Long, Gary Russell, Artem Bilan, Christian Tzolov

Field Summary

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

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
ConsumerEndpointFactoryBean()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	destroy()
MessageHandler	getHandler()
AbstractEndpoint	getObject()
Class<?>	getObjectType()
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	setAdviceChain(List<Advice> adviceChain)
void	setAutoStartup(Boolean autoStartup)
void	setBeanClassLoader(ClassLoader classLoader)
void	setBeanFactory(BeanFactory beanFactory)
void	setBeanName(String beanName)
void	setChannelResolver(DestinationResolver<MessageChannel> channelResolver)	Specify the DestinationResolver strategy to use.
void	setHandler(Object handler)
void	setInputChannel(MessageChannel inputChannel)
void	setInputChannelName(String inputChannelName)
void	setPhase(int phase)
void	setPollerMetadata(PollerMetadata pollerMetadata)
void	setReactiveCustomizer(Function<? super reactor.core.publisher.Flux<Message<?>>,? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer)
void	setRole(String role)
void	setTaskScheduler(TaskScheduler taskScheduler)
void	start()
void	stop()
void	stop(Runnable callback)

Methods inherited from class java.lang.Object

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

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

isSingleton

Constructor Details

ConsumerEndpointFactoryBean

public ConsumerEndpointFactoryBean()

Method Details

setHandler

@Reflective
public void setHandler(Object handler)

getHandler

public MessageHandler getHandler()

setInputChannel

public void setInputChannel(MessageChannel inputChannel)

setInputChannelName

public void setInputChannelName(String inputChannelName)

setPollerMetadata

public void setPollerMetadata(PollerMetadata pollerMetadata)

setReactiveCustomizer

public void setReactiveCustomizer(@Nullable
 Function<? super reactor.core.publisher.Flux<Message<?>>,? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer)

setChannelResolver

public void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)

Specify the DestinationResolver strategy to use. The default is a BeanFactoryChannelResolver.

Parameters:

channelResolver - The channel resolver.

Since:

4.1.3

setBeanClassLoader

public void setBeanClassLoader(ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface BeanClassLoaderAware

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setPhase

public void setPhase(int phase)

setRole

public void setRole(String role)

setBeanName

public void setBeanName(String beanName)

Specified by:

setBeanName in interface BeanNameAware

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

Specified by:

setBeanFactory in interface BeanFactoryAware

setAdviceChain

public void setAdviceChain(List<Advice> adviceChain)

setTaskScheduler

public void setTaskScheduler(TaskScheduler taskScheduler)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

getObject

public AbstractEndpoint getObject()

Specified by:

getObject in interface FactoryBean<AbstractEndpoint>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<AbstractEndpoint>

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean