S - the target ConsumerEndpointSpec implementation type.F - the target BeanNameAware implementation type.H - the target MessageHandler implementation type.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 for endpoints.| Modifier and Type | Field and Description |
|---|---|
protected Collection<Object> |
componentToRegister |
protected F |
endpointFactoryBean |
protected H |
handler |
logger, PARSER, target| Modifier | Constructor and Description |
|---|---|
protected |
EndpointSpec(H handler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
assertHandler() |
abstract S |
autoStartup(boolean autoStartup) |
protected reactor.util.function.Tuple2<F,H> |
doGet() |
Collection<Object> |
getComponentsToRegister() |
S |
id(String id)
Configure the component identifier.
|
abstract S |
phase(int phase) |
S |
poller(java.util.function.Function<PollerFactory,PollerSpec> pollers) |
abstract S |
poller(PollerMetadata pollerMetadata) |
S |
poller(PollerSpec pollerMetadataSpec) |
_this, get, getId, getObject, getObjectType, isSingletonprotected final Collection<Object> componentToRegister
protected H handler
protected F extends BeanNameAware endpointFactoryBean
protected EndpointSpec(H handler)
public S id(String id)
IntegrationComponentSpecbeanName to register the
bean in the application context for this component.id in class IntegrationComponentSpec<S extends EndpointSpec<S,F,H>,reactor.util.function.Tuple2<F extends BeanNameAware,H>>id - the id.public S poller(java.util.function.Function<PollerFactory,PollerSpec> pollers)
pollers - the pollersAbstractPollingEndpoint,
PollerFactorypublic S poller(PollerSpec pollerMetadataSpec)
pollerMetadataSpec - the pollerMetadataSpecAbstractPollingEndpoint,
PollerSpecpublic abstract S poller(PollerMetadata pollerMetadata)
pollerMetadata - the pollerMetadataAbstractPollingEndpointpublic abstract S phase(int phase)
phase - the phase.SmartLifecyclepublic abstract S autoStartup(boolean autoStartup)
autoStartup - the autoStartup.SmartLifecyclepublic Collection<Object> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistrationprotected reactor.util.function.Tuple2<F,H> doGet()
doGet in class IntegrationComponentSpec<S extends EndpointSpec<S,F,H>,reactor.util.function.Tuple2<F extends BeanNameAware,H>>protected void assertHandler()