Package org.springframework.integration.endpoint

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

lifecycleCondition, 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(Exception pollingTaskError)	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()	Subclasses may implement this method to provide component type information.
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(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 Message<?>	receiveMessage()	Obtain the next message (if one is available).
void	registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)	Inject an ObservationRegistry.
void	setObservationConvention(MessageReceiverObservationConvention observationConvention)	Set a custom MessageReceiverObservationConvention for IntegrationObservation.HANDLER.
void	setOutputChannel(MessageChannel outputChannel)	Specify the MessageChannel where Messages should be sent.
void	setOutputChannelName(String outputChannelName)
protected final void	setReceiveMessageSource(Object source)
void	setSendTimeout(long sendTimeout)	Specify the maximum time to wait for a Message to be sent to the output channel.
void	setShouldTrack(boolean shouldTrack)	Specify whether this component should be tracked in the Message History.
void	setSource(MessageSource<?> source)	Specify the source to be polled for Messages.

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

applyReceiveOnlyAdviceChain, getBeanClassLoader, getDefaultErrorChannel, getMaxMessagesPerPoll, getPollingFlux, getTaskExecutor, isReceiveOnlyAdvice, isSyncExecutor, setAdviceChain, setBeanClassLoader, setErrorHandler, setMaxMessagesPerPoll, setTaskExecutor, setTransactionSynchronizationFactory, setTrigger

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

destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

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

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

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

destroy, getManagedName, getManagedType, getOverrides, getThisAs, isLoggingEnabled, registerMetricsCaptor, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

SourcePollingChannelAdapter

public SourcePollingChannelAdapter()

Method Details

setSource

public void setSource(MessageSource<?> source)

Specify the source to be polled for Messages.

Parameters:

source - The message source.

setOutputChannel

public void setOutputChannel(MessageChannel outputChannel)

Specify the MessageChannel where Messages should be sent.

Parameters:

outputChannel - The output channel.

getMessageSource

public MessageSource<?> getMessageSource()

Return this endpoint's source.

Returns:

the source.

Since:

4.3

setOutputChannelName

public void setOutputChannelName(String outputChannelName)

setSendTimeout

public void setSendTimeout(long sendTimeout)

Specify the maximum time to wait for a Message to be sent to the output channel.

Parameters:

sendTimeout - The send timeout.

setShouldTrack

public void setShouldTrack(boolean shouldTrack)

Specify whether this component should be tracked in the Message History.

Specified by:

setShouldTrack in interface TrackableComponent

Parameters:

shouldTrack - true if the component should be tracked.

registerObservationRegistry

public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)

Description copied from interface: IntegrationManagement

Inject an ObservationRegistry. If provided, the MetricsCaptor is ignored. The meters capturing has to be configured as an ObservationHandler on the provided ObservationRegistry.

Specified by:

registerObservationRegistry in interface IntegrationManagement

Parameters:

observationRegistry - the ObservationRegistry to expose observations from the component.

See Also:

• IntegrationManagement.registerMetricsCaptor(MetricsCaptor)

setObservationConvention

public void setObservationConvention(@Nullable
 MessageReceiverObservationConvention observationConvention)

Set a custom MessageReceiverObservationConvention for IntegrationObservation.HANDLER. Ignored if an ObservationRegistry is not configured for this component.

Parameters:

observationConvention - the MessageReceiverObservationConvention to use.

Since:

6.5

isObserved

public boolean isObserved()

Description copied from interface: IntegrationManagement

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

Specified by:

isObserved in interface IntegrationManagement

Returns:

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

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport

isReactive

protected boolean isReactive()

Overrides:

isReactive in class AbstractPollingEndpoint

getReceiveMessageSource

protected Object getReceiveMessageSource()

Overrides:

getReceiveMessageSource in class AbstractPollingEndpoint

setReceiveMessageSource

protected final void setReceiveMessageSource(Object source)

Overrides:

setReceiveMessageSource in class AbstractPollingEndpoint

doStart

protected void doStart()

Description copied from class: AbstractEndpoint

Subclasses must implement this method with the start behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:

doStart in class AbstractPollingEndpoint

doStop

protected void doStop()

Description copied from class: AbstractEndpoint

Subclasses must implement this method with the stop behavior. This method will be invoked while holding the AbstractEndpoint.lifecycleLock.

Overrides:

doStop in class AbstractPollingEndpoint

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractPollingEndpoint

getOutputChannel

public MessageChannel getOutputChannel()

handleMessage

protected void handleMessage(Message<?> messageArg)

Description copied from class: AbstractPollingEndpoint

Handle a message.

Specified by:

handleMessage in class AbstractPollingEndpoint

Parameters:

messageArg - The message.

receiveMessage

protected Message<?> receiveMessage()

Description copied from class: AbstractPollingEndpoint

Obtain the next message (if one is available). MAY return null if no message is immediately available.

Specified by:

receiveMessage in class AbstractPollingEndpoint

Returns:

The message or null.

messageReceived

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

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

Overrides:

messageReceived in class AbstractPollingEndpoint

Parameters:

holder - the resource holder for this component.

message - the received message.

donePollingTask

protected void donePollingTask(@Nullable
 Exception pollingTaskError)

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

Overrides:

donePollingTask in class AbstractPollingEndpoint

Parameters:

pollingTaskError - an optional error as a result of the polling task.

getResourceToBind

protected Object getResourceToBind()

Description copied from class: AbstractPollingEndpoint

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

Overrides:

getResourceToBind in class AbstractPollingEndpoint

Returns:

The resource, or null if transaction synchronization is not required.

getResourceKey

protected String getResourceKey()

Description copied from class: AbstractPollingEndpoint

Return the key under which the resource will be made available as an attribute on the IntegrationResourceHolder. The default ExpressionEvaluatingTransactionSynchronizationProcessor makes this attribute available as a variable in SpEL expressions.

Overrides:

getResourceKey in class AbstractPollingEndpoint

Returns:

The key, or null (default) if the resource shouldn't be made available as a attribute.