クラス AbstractMessageHandler
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
- 実装されたすべてのインターフェース:
org.reactivestreams.Subscriber<Message<?>>
、Aware
、BeanFactoryAware
、BeanNameAware
、DisposableBean
、InitializingBean
、ApplicationContextAware
、Ordered
、ExpressionCapable
、Orderable
、IntegrationPattern
、NamedComponent
、IntegrationManagement
、TrackableComponent
、MessageHandler
、reactor.core.CoreSubscriber<Message<?>>
- 既知の直属サブクラス
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<?>>
MessageHandler
実装の基本クラス。- 作成者:
- David Turanski, Artem Bilan
ネストされたクラスのサマリー
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドサマリー
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明void
handleMessage
(Message<?> message) protected abstract void
handleMessageInternal
(Message<?> message) void
void
onError
(ThrowableSE throwable) void
void
onSubscribe
(org.reactivestreams.Subscription subscription) void
setObservationConvention
(MessageReceiverObservationConvention observationConvention) クラス 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
クラス 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
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
AbstractMessageHandler
public AbstractMessageHandler()
メソッドの詳細
setObservationConvention
public void setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention) IntegrationObservation.HANDLER
にカスタムMessageReceiverObservationConvention
を設定します。このコンポーネントに対してObservationRegistry
が構成されていない場合は無視されます。- パラメーター:
observationConvention
- 使用するMessageReceiverObservationConvention
。- 導入:
- 6.0
handleMessage
- 次で指定:
- インターフェース
MessageHandler
のhandleMessage
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription) onError
- 次で指定:
- インターフェース
org.reactivestreams.Subscriber<Message<?>>
のonError
onComplete
public void onComplete()- 次で指定:
- インターフェース
org.reactivestreams.Subscriber<Message<?>>
のonComplete
onNext
- 次で指定:
- インターフェース
org.reactivestreams.Subscriber<Message<?>>
のonNext
handleMessageInternal