Package org.springframework.integration.handler

Class AbstractMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

Direct Known Subclasses:

AbstractInternetProtocolSendingMessageHandler, AbstractMessageProducingHandler, AbstractMessageRouter, AbstractMqttMessageHandler, AbstractXmppConnectionAwareMessageHandler, ApplicationEventPublishingMessageHandler, ByteStreamWritingMessageHandler, CharacterStreamWritingMessageHandler, CorrelatingMessageBarrier, ExpressionEvaluatingMessageHandler, FileTransferringMessageHandler, HazelcastCacheWritingMessageHandler, JdbcMessageHandler, JmsSendingMessageHandler, LoggingHandler, MailSendingMessageHandler, MethodInvokingMessageHandler, MongoDbStoringMessageHandler, NotificationPublishingMessageHandler, RabbitStreamMessageHandler, RedisPublishingMessageHandler, RedisQueueOutboundChannelAdapter, RedisStoreWritingMessageHandler, StompMessageHandler, StoredProcMessageHandler, TcpSendingMessageHandler, WebSocketOutboundMessageHandler

public abstract class AbstractMessageHandler
extends MessageHandlerSupport
implements MessageHandler, reactor.core.CoreSubscriber<Message<?>>

Base class for MessageHandler implementations.

Author:

David Turanski, Artem Bilan

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.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.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
AbstractMessageHandler()

Method Summary

Modifier and Type	Method	Description
void	handleMessage(Message<?> message)
protected abstract void	handleMessageInternal(Message<?> message)
void	onComplete()
void	onError(Throwable throwable)
void	onNext(Message<?> message)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	setObservationConvention(MessageReceiverObservationConvention observationConvention)	Set a custom MessageReceiverObservationConvention for IntegrationObservation.HANDLER.

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

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

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, 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 reactor.core.CoreSubscriber

currentContext

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

getThisAs

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

getBeanName, getComponentName

Constructor Details

AbstractMessageHandler

public AbstractMessageHandler()

Method Details

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.0

handleMessage

public void handleMessage(Message<?> message)

Specified by:

handleMessage in interface MessageHandler

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface reactor.core.CoreSubscriber<Message<?>>

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<Message<?>>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.reactivestreams.Subscriber<Message<?>>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<Message<?>>

onNext

public void onNext(Message<?> message)

Specified by:

onNext in interface org.reactivestreams.Subscriber<Message<?>>

handleMessageInternal

protected abstract void handleMessageInternal(Message<?> message)