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, targetloggerDEFAULT_PHASEOBJECT_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, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected H handler
protected F extends BeanNameAware endpointFactoryBean
protected EndpointSpec(H handler)
public S id(StringSE id)
IntegrationComponentSpecbeanName として使用されます。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, PollerFactorypublic S poller(PollerSpec pollerMetadataSpec)
pollerMetadataSpec - pollerMetadataSpecAbstractPollingEndpoint, PollerSpecpublic abstract S poller(PollerMetadata pollerMetadata)
pollerMetadata - pollerMetadataAbstractPollingEndpointpublic abstract S phase(int phase)
phase - フェーズ。SmartLifecyclepublic abstract S autoStartup(boolean autoStartup)
autoStartup - autoStartup。SmartLifecyclepublic abstract S role(StringSE role)
role - このエンドポイントのロール。SmartLifecycle, SmartLifecycleRoleControllerpublic 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 登録順序を保持するルーター構成に使用されます。