public abstract class AbstractMessageHandler extends MessageHandlerSupport implements MessageHandler, reactor.core.CoreSubscriber<Message<?>>
MessageHandler
implementations.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
AbstractMessageHandler() |
Modifier and Type | Method and 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) |
buildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getIntegrationPatternType, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
errorCount, handleCount
getBeanName, getComponentName
public void handleMessage(Message<?> message)
handleMessage
in interface MessageHandler
public void onSubscribe(org.reactivestreams.Subscription subscription)
public void onError(Throwable throwable)
onError
in interface org.reactivestreams.Subscriber<Message<?>>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<Message<?>>
public void onNext(Message<?> message)
onNext
in interface org.reactivestreams.Subscriber<Message<?>>
protected abstract void handleMessageInternal(Message<?> message)