public class ConsumerEndpointFactoryBean extends java.lang.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
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.Constructor and Description |
---|
ConsumerEndpointFactoryBean() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
void |
destroy() |
AbstractEndpoint |
getObject() |
java.lang.Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
boolean |
isSingleton() |
void |
setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain) |
void |
setAutoStartup(java.lang.Boolean autoStartup) |
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setBeanName(java.lang.String beanName) |
void |
setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)
Specify the
DestinationResolver strategy to use. |
void |
setHandler(org.springframework.messaging.MessageHandler handler) |
void |
setInputChannel(org.springframework.messaging.MessageChannel inputChannel) |
void |
setInputChannelName(java.lang.String inputChannelName) |
void |
setPhase(int phase) |
void |
setPollerMetadata(PollerMetadata pollerMetadata) |
void |
setRole(java.lang.String role) |
void |
setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
public void setHandler(org.springframework.messaging.MessageHandler handler)
public void setInputChannel(org.springframework.messaging.MessageChannel inputChannel)
public void setInputChannelName(java.lang.String inputChannelName)
public void setPollerMetadata(PollerMetadata pollerMetadata)
public void setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> channelResolver)
DestinationResolver
strategy to use.
The default is a BeanFactoryChannelResolver.channelResolver
- The channel resolver.public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader
in interface org.springframework.beans.factory.BeanClassLoaderAware
public void setAutoStartup(java.lang.Boolean autoStartup)
public void setPhase(int phase)
public void setRole(java.lang.String role)
public void setBeanName(java.lang.String beanName)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
public void setAdviceChain(java.util.List<org.aopalliance.aop.Advice> adviceChain)
public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<AbstractEndpoint>
public AbstractEndpoint getObject() throws java.lang.Exception
getObject
in interface org.springframework.beans.factory.FactoryBean<AbstractEndpoint>
java.lang.Exception
public java.lang.Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<AbstractEndpoint>
public boolean isAutoStartup()
isAutoStartup
in interface org.springframework.context.SmartLifecycle
public int getPhase()
getPhase
in interface org.springframework.context.Phased
getPhase
in interface org.springframework.context.SmartLifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle
public void destroy() throws java.lang.Exception
destroy
in interface org.springframework.beans.factory.DisposableBean
java.lang.Exception