Class SourcePollingChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<SourcePollingChannelAdapterSpec, reactor.util.function.Tuple2<SourcePollingChannelAdapterFactoryBean, MessageSource<?>>>

org.springframework.integration.dsl.EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

org.springframework.integration.dsl.SourcePollingChannelAdapterSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<reactor.util.function.Tuple2<SourcePollingChannelAdapterFactoryBean, MessageSource<?>>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class SourcePollingChannelAdapterSpec
extends EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

Since:

5.0

Author:

Artem Bilan

Field Summary

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

componentsToRegister, endpointFactoryBean, handler

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

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SourcePollingChannelAdapterSpec(MessageSource<?> messageSource)

Method Summary

Modifier and Type	Method	Description
SourcePollingChannelAdapterSpec	autoStartup(boolean autoStartup)
SourcePollingChannelAdapterSpec	phase(int phase)
SourcePollingChannelAdapterSpec	poller(@Nullable PollerMetadata pollerMetadata)
SourcePollingChannelAdapterSpec	role(String role)	Specify the role for the endpoint.
SourcePollingChannelAdapterSpec	sendTimeout(long sendTimeout)	The timeout for blocking send on channels.
SourcePollingChannelAdapterSpec	taskScheduler(TaskScheduler taskScheduler)	Set a TaskScheduler for polling tasks.

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

assertHandler, doGet, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller

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

_this, afterPropertiesSet, destroy, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

SourcePollingChannelAdapterSpec

protected SourcePollingChannelAdapterSpec(MessageSource<?> messageSource)

Method Details

phase

public SourcePollingChannelAdapterSpec phase(int phase)

Specified by:

phase in class EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

Parameters:

phase - the phase.

Returns:

the endpoint spec.

See Also:

• SmartLifecycle

autoStartup

public SourcePollingChannelAdapterSpec autoStartup(boolean autoStartup)

Specified by:

autoStartup in class EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

Parameters:

autoStartup - the autoStartup.

Returns:

the endpoint spec

See Also:

• SmartLifecycle

poller

public SourcePollingChannelAdapterSpec poller(@Nullable PollerMetadata pollerMetadata)

Specified by:

poller in class EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

Parameters:

pollerMetadata - the pollerMetadata

Returns:

the endpoint spec.

See Also:

• AbstractPollingEndpoint

role

public SourcePollingChannelAdapterSpec role(String role)

Description copied from class: EndpointSpec

Specify the role for the endpoint. Such endpoints can be started/stopped as a group.

Specified by:

role in class EndpointSpec<SourcePollingChannelAdapterSpec, SourcePollingChannelAdapterFactoryBean, MessageSource<?>>

Parameters:

role - the role for this endpoint.

Returns:

the endpoint spec

See Also:

• SmartLifecycle
• SmartLifecycleRoleController

taskScheduler

public SourcePollingChannelAdapterSpec taskScheduler(TaskScheduler taskScheduler)

Set a TaskScheduler for polling tasks.

Parameters:

taskScheduler - the TaskScheduler for polling tasks.

Returns:

the spec

Since:

6.4

sendTimeout

public SourcePollingChannelAdapterSpec sendTimeout(long sendTimeout)

The timeout for blocking send on channels.

Parameters:

sendTimeout - the timeout to use.

Returns:

the spec.

Since:

6.3.9