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<org.springframework.messaging.Message<?>>,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.core.Ordered,ExpressionCapable,Orderable,IntegrationPattern,NamedComponent,IntegrationManagement,TrackableComponent,org.springframework.messaging.MessageHandler,reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
- Direct Known Subclasses:
AbstractMessageProducingHandler,AbstractMessageRouter,CorrelatingMessageBarrier,ExpressionEvaluatingMessageHandler,LoggingHandler,MethodInvokingMessageHandler
public abstract class AbstractMessageHandler extends MessageHandlerSupport implements org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
Base class for
MessageHandler implementations.-
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, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
Constructors Constructor Description AbstractMessageHandler() -
Method Summary
Modifier and Type Method Description voidhandleMessage(org.springframework.messaging.Message<?> message)protected abstract voidhandleMessageInternal(org.springframework.messaging.Message<?> message)voidonComplete()voidonError(java.lang.Throwable throwable)voidonNext(org.springframework.messaging.Message<?> message)voidonSubscribe(org.reactivestreams.Subscription subscription)Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAsMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
AbstractMessageHandler
public AbstractMessageHandler()
-
-
Method Details
-
handleMessage
public void handleMessage(org.springframework.messaging.Message<?> message)- Specified by:
handleMessagein interfaceorg.springframework.messaging.MessageHandler
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription)- Specified by:
onSubscribein interfacereactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>- Specified by:
onSubscribein interfaceorg.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>
-
onError
public void onError(java.lang.Throwable throwable)- Specified by:
onErrorin interfaceorg.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>
-
onComplete
public void onComplete()- Specified by:
onCompletein interfaceorg.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>
-
onNext
public void onNext(org.springframework.messaging.Message<?> message)- Specified by:
onNextin interfaceorg.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>
-
handleMessageInternal
protected abstract void handleMessageInternal(org.springframework.messaging.Message<?> message)
-