S
- ターゲット ConsumerEndpointSpec
実装型。F
- ターゲット BeanNameAware
実装型。H
- ターゲット MessageHandler
実装型。public abstract class EndpointSpec<S extends EndpointSpec<S,F,H>,F extends BeanNameAware,H> extends IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>> implements ComponentsRegistration
IntegrationComponentSpec
。修飾子と型 | フィールドと説明 |
---|---|
protected MapSE<ObjectSE, StringSE> | componentsToRegister |
protected F | endpointFactoryBean |
protected H | handler |
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | EndpointSpec(H handler) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | assertHandler() |
abstract S | autoStartup(boolean autoStartup) |
protected reactor.util.function.Tuple2<F, H> | doGet() |
MapSE<ObjectSE, StringSE> | getComponentsToRegister() |
S | id(StringSE id) コンポーネント識別子を構成します。 |
protected MessageChannel | obtainInputChannelFromFlow(IntegrationFlow subFlow) 提供された IntegrationFlow の入力として MessageChannel を取得するか、IntegrationFlow を作成して、提供されたフローを新しいものにラップしてみてください。 |
protected MessageChannel | obtainInputChannelFromFlow(IntegrationFlow subFlow, boolean evaluateInternalBuilder) 提供された IntegrationFlow の入力として MessageChannel を取得するか、IntegrationFlow を作成して、提供されたフローを新しいものにラップしてみてください。 |
abstract S | phase(int phase) |
S | poller(java.util.function.FunctionSE<PollerFactory, PollerSpec> pollers) |
abstract S | poller(PollerMetadata pollerMetadata) |
S | poller(PollerSpec pollerMetadataSpec) |
abstract S | role(StringSE role) エンドポイントのロールを指定します。 |
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected H handler
protected F extends BeanNameAware endpointFactoryBean
protected EndpointSpec(H handler)
public S id(StringSE id)
IntegrationComponentSpec
beanName
として使用されます。IntegrationComponentSpec<S extends EndpointSpec<S, F, H>,reactor.util.function.Tuple2<F extends BeanNameAware, H>>
の id
id
- ID。public S poller(java.util.function.FunctionSE<PollerFactory,PollerSpec> pollers)
pollers
- ポーラー AbstractPollingEndpoint
, PollerFactory
public S poller(PollerSpec pollerMetadataSpec)
pollerMetadataSpec
- pollerMetadataSpecAbstractPollingEndpoint
, PollerSpec
public abstract S poller(PollerMetadata pollerMetadata)
pollerMetadata
- pollerMetadataAbstractPollingEndpoint
public abstract S phase(int phase)
phase
- フェーズ。SmartLifecycle
public abstract S autoStartup(boolean autoStartup)
autoStartup
- autoStartup。SmartLifecycle
public abstract S role(StringSE role)
role
- このエンドポイントのロール。SmartLifecycle
, SmartLifecycleRoleController
public MapSE<ObjectSE,StringSE> getComponentsToRegister()
ComponentsRegistration
の getComponentsToRegister
protected reactor.util.function.Tuple2<F,H> doGet()
IntegrationComponentSpec<S extends EndpointSpec<S, F, H>,reactor.util.function.Tuple2<F extends BeanNameAware, H>>
の doGet
protected void assertHandler()
protected MessageChannel obtainInputChannelFromFlow(IntegrationFlow subFlow)
IntegrationFlow
の入力として MessageChannel
を取得するか、IntegrationFlow
を作成して、提供されたフローを新しいものにラップしてみてください。subFlow
- 入力チャネルを抽出するための IntegrationFlow
。protected MessageChannel obtainInputChannelFromFlow(IntegrationFlow subFlow, boolean evaluateInternalBuilder)
IntegrationFlow
の入力として MessageChannel
を取得するか、IntegrationFlow
を作成して、提供されたフローを新しいものにラップしてみてください。subFlow
- 入力チャネルを抽出するための IntegrationFlow
。evaluateInternalBuilder
- 内部 IntegrationFlowDefinition
を IntegrationFlow
コンポーネントに対して評価する必要がある場合、または将来のユースケースのために componentsToRegister
のビルダーとして残す必要がある場合は true。たとえば、ビルダーは、親子依存関係の Bean 登録順序を保持するルーター構成に使用されます。