クラス 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、ComponentSourceAware、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

  • コンストラクターの詳細

    • AbstractMessageHandler

      public AbstractMessageHandler()

  • メソッドの詳細

    • setObservationConvention

      public void setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention)
      IntegrationObservation.HANDLER にカスタム MessageReceiverObservationConvention を設定します。このコンポーネントに対して ObservationRegistry が構成されていない場合は無視されます。
      パラメーター:
      observationConvention - 使用する MessageReceiverObservationConvention。
      導入:
      6.0

    • handleMessage

      public void handleMessage(Message<?> message)
      次で指定:
      インターフェース MessageHandler の handleMessage 

    • onSubscribe

      public void onSubscribe(org.reactivestreams.Subscription subscription)
      次で指定:
      インターフェース reactor.core.CoreSubscriber<Message<?>> の onSubscribe 
      次で指定:
      インターフェース org.reactivestreams.Subscriber<Message<?>> の onSubscribe 

    • onError

      public void onError(ThrowableSE throwable)
      次で指定:
      インターフェース org.reactivestreams.Subscriber<Message<?>> の onError 

    • onComplete

      public void onComplete()
      次で指定:
      インターフェース org.reactivestreams.Subscriber<Message<?>> の onComplete 

    • onNext

      public void onNext(Message<?> message)
      次で指定:
      インターフェース org.reactivestreams.Subscriber<Message<?>> の onNext 

    • handleMessageInternal

      protected abstract void handleMessageInternal(Message<?> message)