Class SourcePollingChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.AbstractPollingEndpoint

org.springframework.integration.endpoint.SourcePollingChannelAdapter

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent

public class SourcePollingChannelAdapter
extends AbstractPollingEndpoint
implements TrackableComponent, IntegrationManagement

A Channel Adapter implementation for connecting a MessageSource to a MessageChannel.

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Christian Tzolov

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.endpoint.AbstractPollingEndpoint

DEFAULT_POLLING_PERIOD

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
SourcePollingChannelAdapter()

Method Summary

Modifier and Type

Method

Description

protected void

donePollingTask(@Nullable Message<?> message)

Stop an observation (and close its scope) previously started from the messageReceived(IntegrationResourceHolder, Message).

protected void

doStart()

Subclasses must implement this method with the start behavior.

protected void

doStop()

Subclasses must implement this method with the stop behavior.

String

getComponentType()

MessageSource<?>

getMessageSource()

Return this endpoint's source.

MessageChannel

getOutputChannel()

protected Object

getReceiveMessageSource()

protected String

getResourceKey()

Return the key under which the resource will be made available as an attribute on the IntegrationResourceHolder.

protected Object

getResourceToBind()

Return a resource (MessageSource etc.) to bind when using transaction synchronization.

protected void

handleMessage(Message<?> messageArg)

Handle a message.

boolean

isObserved()

True if this implementation is going to deal with a registry other than the ObservationRegistry.NOOP instance.

protected boolean

isReactive()

protected void

messageReceived(@Nullable IntegrationResourceHolder holder, Message<?> message)

Start an observation (and open scope) for the received message.

protected void

onInit()

Subclasses may implement this for initialization logic.

protected @Nullable Message<?>

receiveMessage()

Obtain the next message (if one is available).

void

registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)

Inject an ObservationRegistry.

void

setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention)

Set a custom MessageReceiverObservationConvention for IntegrationObservation.HANDLER.

void

setOutputChannel(MessageChannel outputChannel)

Specify the MessageChannel where Messages should be sent.

void