public abstract class AbstractMessageHandler extends MessageHandlerSupport implements MessageHandler, reactor.core.CoreSubscriber<Message<?>>
MessageHandler 実装の基本クラス。IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCEMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| コンストラクターと説明 |
|---|
AbstractMessageHandler() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | handleMessage(Message<?> message) |
protected abstract void | handleMessageInternal(Message<?> message) |
void | onComplete() |
void | onError(ThrowableSE throwable) |
void | onNext(Message<?> message) |
void | onSubscribe(org.reactivestreams.Subscription subscription) |
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetThisAsgetBeanName, getComponentNamepublic void handleMessage(Message<?> message)
MessageHandler の handleMessage public void onSubscribe(org.reactivestreams.Subscription subscription)
public void onError(ThrowableSE throwable)
org.reactivestreams.Subscriber<Message<?>> の onError public void onComplete()
org.reactivestreams.Subscriber<Message<?>> の onComplete public void onNext(Message<?> message)
org.reactivestreams.Subscriber<Message<?>> の onNext protected abstract void handleMessageInternal(Message<?> message)