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
| 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.BeanClassLoaderAwarepublic 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.BeanNameAwarepublic void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAwarepublic 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.InitializingBeanjava.lang.Exceptionpublic 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.Exceptionpublic java.lang.Class<?> getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBean<AbstractEndpoint>public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic void destroy()
throws java.lang.Exception
destroy in interface org.springframework.beans.factory.DisposableBeanjava.lang.Exception