Class AbstractMessageHandler

All Implemented Interfaces:
org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
Direct Known Subclasses:
AbstractInternetProtocolSendingMessageHandler, AbstractMessageProducingHandler, AbstractMessageRouter, AbstractMqttMessageHandler, AbstractXmppConnectionAwareMessageHandler, ApplicationEventPublishingMessageHandler, ByteStreamWritingMessageHandler, CacheWritingMessageHandler, CharacterStreamWritingMessageHandler, CorrelatingMessageBarrier, ExpressionEvaluatingMessageHandler, FileTransferringMessageHandler, JdbcMessageHandler, JmsSendingMessageHandler, LoggingHandler, MailSendingMessageHandler, MethodInvokingMessageHandler, MongoDbStoringMessageHandler, NotificationPublishingMessageHandler, RedisPublishingMessageHandler, RedisQueueOutboundChannelAdapter, RedisStoreWritingMessageHandler, StompMessageHandler, StoredProcMessageHandler, TcpSendingMessageHandler, WebSocketOutboundMessageHandler

public abstract class AbstractMessageHandler
extends MessageHandlerSupport
implements MessageHandler, reactor.core.CoreSubscriber<Message<?>>
Base class for MessageHandler implementations.
Author:
David Turanski, Artem Bilan
  • Constructor Details

  • Method Details

    • handleMessage

      public void handleMessage​(Message<?> message)
      Specified by:
      handleMessage in interface MessageHandler
    • onSubscribe

      public void onSubscribe​(org.reactivestreams.Subscription subscription)
      Specified by:
      onSubscribe in interface reactor.core.CoreSubscriber<Message<?>>
      Specified by:
      onSubscribe in interface org.reactivestreams.Subscriber<Message<?>>
    • onError

      public void onError​(Throwable throwable)
      Specified by:
      onError in interface org.reactivestreams.Subscriber<Message<?>>
    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.reactivestreams.Subscriber<Message<?>>
    • onNext

      public void onNext​(Message<?> message)
      Specified by:
      onNext in interface org.reactivestreams.Subscriber<Message<?>>
    • handleMessageInternal

      protected abstract void handleMessageInternal​(Message<?> message)