クラス ConsumerEndpointFactoryBean
java.lang.ObjectSE
org.springframework.integration.config.ConsumerEndpointFactoryBean
- 実装されたすべてのインターフェース:
Aware
、BeanClassLoaderAware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、FactoryBean<AbstractEndpoint>
、InitializingBean
、Lifecycle
、Phased
、SmartLifecycle
public class ConsumerEndpointFactoryBean
extends ObjectSE
implements FactoryBean<AbstractEndpoint>, BeanFactoryAware, BeanNameAware, BeanClassLoaderAware, InitializingBean, SmartLifecycle, DisposableBean
AbstractEndpoint
集団用の FactoryBean
実装。必要なすべてのプロパティとライフサイクルを制御します。提供されている MessageChannel
実装では、PollableChannel
の PollingConsumer
、SubscribableChannel
の EventDrivenConsumer
、他のすべてのチャネル実装の ReactiveStreamsConsumer
を実装します。- 作成者:
- Mark Fisher, Oleg Zhurakousky, Josh Long, Gary Russell, Artem Bilan, Christian Tzolov
フィールドサマリー
インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
OBJECT_TYPE_ATTRIBUTE
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明void
void
destroy()
ClassSE<?>
int
getPhase()
boolean
boolean
void
setAdviceChain
(ListSE<Advice> adviceChain) void
setAutoStartup
(BooleanSE autoStartup) void
setBeanClassLoader
(ClassLoaderSE classLoader) void
setBeanFactory
(BeanFactory beanFactory) void
setBeanName
(StringSE beanName) void
setChannelResolver
(DestinationResolver<MessageChannel> channelResolver) 使用するDestinationResolver
戦略を指定します。void
setHandler
(ObjectSE handler) void
setInputChannel
(MessageChannel inputChannel) void
setInputChannelName
(StringSE inputChannelName) void
setPhase
(int phase) void
setPollerMetadata
(PollerMetadata pollerMetadata) void
setReactiveCustomizer
(FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer) void
void
setTaskScheduler
(TaskScheduler taskScheduler) void
start()
void
stop()
void
stop
(RunnableSE callback) クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド
isSingleton
コンストラクターの詳細
ConsumerEndpointFactoryBean
public ConsumerEndpointFactoryBean()
メソッドの詳細
setHandler
getHandler
setInputChannel
setInputChannelName
setPollerMetadata
setReactiveCustomizer
public void setReactiveCustomizer(@Nullable FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer) setChannelResolver
使用するDestinationResolver
戦略を指定します。デフォルトは BeanFactoryChannelResolver です。- パラメーター:
channelResolver
- チャネルリゾルバー。- 導入:
- 4.1.3
setBeanClassLoader
- 次で指定:
- インターフェース
BeanClassLoaderAware
のsetBeanClassLoader
setAutoStartup
setPhase
public void setPhase(int phase) setRole
setBeanName
- 次で指定:
- インターフェース
BeanNameAware
のsetBeanName
setBeanFactory
- 次で指定:
- インターフェース
BeanFactoryAware
のsetBeanFactory
setAdviceChain
setTaskScheduler
afterPropertiesSet
public void afterPropertiesSet()- 次で指定:
- インターフェース
InitializingBean
のafterPropertiesSet
getObject
- 次で指定:
- インターフェース
FactoryBean<AbstractEndpoint>
のgetObject
getObjectType
- 次で指定:
- インターフェース
FactoryBean<AbstractEndpoint>
のgetObjectType
isAutoStartup
public boolean isAutoStartup()- 次で指定:
- インターフェース
SmartLifecycle
のisAutoStartup
getPhase
public int getPhase()- 次で指定:
- インターフェース
Phased
のgetPhase
- 次で指定:
- インターフェース
SmartLifecycle
のgetPhase
isRunning
public boolean isRunning()start
public void start()stop
public void stop()stop
- 次で指定:
- インターフェース
SmartLifecycle
のstop
destroy
public void destroy()- 次で指定:
- インターフェース
DisposableBean
のdestroy