クラス 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)