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
コンストラクターの概要
コンストラクター
コンストラクター
説明
ConsumerEndpointFactoryBean()
メソッドのサマリー
修飾子と型
メソッド
説明
void
afterPropertiesSet()
void
destroy()
MessageHandler
getHandler()
AbstractEndpoint
getObject()
ClassSE<?>
getObjectType()
int
getPhase()
boolean
isAutoStartup()
boolean
isRunning()
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
setRole(StringSE role)
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
  @Reflective public void setHandler(ObjectSE handler)
- getHandler
  public MessageHandler getHandler()
- setInputChannel
  public void setInputChannel(MessageChannel inputChannel)
- setInputChannelName
  public void setInputChannelName(StringSE inputChannelName)
- setPollerMetadata
  public void setPollerMetadata(PollerMetadata pollerMetadata)
- setReactiveCustomizer
  public void setReactiveCustomizer(@Nullable FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer)
- setChannelResolver
  public void setChannelResolver(DestinationResolver<MessageChannel> channelResolver)
  使用する DestinationResolver 戦略を指定します。デフォルトは BeanFactoryChannelResolver です。
  パラメーター:
  channelResolver - チャネルリゾルバー。
  導入:
  4.1.3
- setBeanClassLoader
  public void setBeanClassLoader(ClassLoaderSE classLoader)
  次で指定:
  インターフェース BeanClassLoaderAware の setBeanClassLoader
- setAutoStartup
  public void setAutoStartup(BooleanSE autoStartup)
- setPhase
  public void setPhase(int phase)
- setRole
  public void setRole(StringSE role)
- setBeanName
  public void setBeanName(StringSE beanName)
  次で指定:
  インターフェース BeanNameAware の setBeanName
- setBeanFactory
  public void setBeanFactory(BeanFactory beanFactory)
  次で指定:
  インターフェース BeanFactoryAware の setBeanFactory
- setAdviceChain
  public void setAdviceChain(ListSE<Advice> adviceChain)
- setTaskScheduler
  public void setTaskScheduler(TaskScheduler taskScheduler)
- afterPropertiesSet
  public void afterPropertiesSet()
  次で指定:
  インターフェース InitializingBean の afterPropertiesSet
- getObject
  public AbstractEndpoint getObject()
  次で指定:
  インターフェース FactoryBean<AbstractEndpoint> の getObject
- getObjectType
  public ClassSE<?> getObjectType()
  次で指定:
  インターフェース FactoryBean<AbstractEndpoint> の getObjectType
- isAutoStartup
  public boolean isAutoStartup()
  次で指定:
  インターフェース SmartLifecycle の isAutoStartup
- getPhase
  public int getPhase()
  次で指定:
  インターフェース Phased の getPhase
  次で指定:
  インターフェース SmartLifecycle の getPhase
- isRunning
  public boolean isRunning()
  次で指定:
  インターフェース Lifecycle の isRunning
- start
  public void start()
  次で指定:
  インターフェース Lifecycle の start
- stop
  public void stop()
  次で指定:
  インターフェース Lifecycle の stop
- stop
  public void stop(RunnableSE callback)
  次で指定:
  インターフェース SmartLifecycle の stop
- destroy
  public void destroy()
  次で指定:
  インターフェース DisposableBean の destroy

クラス ConsumerEndpointFactoryBean

フィールドのサマリー

インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.beans.factory.FactoryBean から継承されたメソッド

コンストラクターの詳細

ConsumerEndpointFactoryBean

メソッドの詳細

setHandler

getHandler

setInputChannel

setInputChannelName

setPollerMetadata

setReactiveCustomizer

setChannelResolver

setBeanClassLoader

setAutoStartup

setPhase

setRole

setBeanName

setBeanFactory

setAdviceChain

setTaskScheduler

afterPropertiesSet

getObject

getObjectType

isAutoStartup

getPhase

isRunning

start

stop

stop

destroy