org.springframework.integration.dsl

Class EndpointSpec<S extends EndpointSpec<S,F,H>,F extends org.springframework.beans.factory.BeanNameAware,H>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>>

org.springframework.integration.dsl.EndpointSpec<S,F,H>

Type Parameters:

S - the target ConsumerEndpointSpec implementation type.

F - the target BeanNameAware implementation type.

H - the target MessageHandler implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<reactor.util.function.Tuple2<F,H>>, ComponentsRegistration

Direct Known Subclasses:

ConsumerEndpointSpec, SourcePollingChannelAdapterSpec

public abstract class EndpointSpec<S extends EndpointSpec<S,F,H>,F extends org.springframework.beans.factory.BeanNameAware,H>
extends IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>>
implements ComponentsRegistration

An IntegrationComponentSpec for endpoints.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<Object,String>	componentsToRegister
protected F	endpointFactoryBean
protected H	handler

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EndpointSpec(H handler)

Method Summary

Modifier and Type	Method and Description
protected void	assertHandler()
abstract S	autoStartup(boolean autoStartup)
protected reactor.util.function.Tuple2<F,H>	doGet()
Map<Object,String>	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)

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

componentsToRegister

protected final Map<Object,String> componentsToRegister

handler

protected H handler

endpointFactoryBean

protected F extends org.springframework.beans.factory.BeanNameAware endpointFactoryBean

Constructor Detail

EndpointSpec

protected EndpointSpec(H handler)

Method Detail

id

public S id(String id)

Description copied from class: IntegrationComponentSpec

Configure the component identifier. Used as the beanName to register the bean in the application context for this component.

Overrides:

id in class IntegrationComponentSpec<S extends EndpointSpec<S,F,H>,reactor.util.function.Tuple2<F extends org.springframework.beans.factory.BeanNameAware,H>>

Parameters:

id - the id.

Returns:

the spec.

poller

public S poller(java.util.function.Function<PollerFactory,PollerSpec> pollers)

Parameters:

pollers - the pollers

Returns:

the endpoint spec.

See Also:

AbstractPollingEndpoint, PollerFactory

poller

public S poller(PollerSpec pollerMetadataSpec)

Parameters:

pollerMetadataSpec - the pollerMetadataSpec

Returns:

the endpoint spec.

See Also:

AbstractPollingEndpoint, PollerSpec

poller

public abstract S poller(PollerMetadata pollerMetadata)

Parameters:

pollerMetadata - the pollerMetadata

Returns:

the endpoint spec.

See Also:

AbstractPollingEndpoint

phase

public abstract S phase(int phase)

Parameters:

phase - the phase.

Returns:

the endpoint spec.

See Also:

SmartLifecycle

autoStartup

public abstract S autoStartup(boolean autoStartup)

Parameters:

autoStartup - the autoStartup.

Returns:

the endpoint spec

See Also:

SmartLifecycle

getComponentsToRegister

public Map<Object,String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration

doGet

protected reactor.util.function.Tuple2<F,H> doGet()

Overrides:

doGet in class IntegrationComponentSpec<S extends EndpointSpec<S,F,H>,reactor.util.function.Tuple2<F extends org.springframework.beans.factory.BeanNameAware,H>>

assertHandler

protected void assertHandler()