public abstract class AbstractMessageHandler extends MessageHandlerSupport implements MessageHandler, reactor.core.CoreSubscriber<Message<?>>
MessageHandler implementations.IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEHIGHEST_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, shouldTrackafterPropertiesSet, 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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waiterrorCount, handleCountgetBeanName, getComponentNamepublic void handleMessage(Message<?> message)
handleMessage in interface MessageHandlerpublic 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)